Skip to content
Snippets Groups Projects
Commit a38baaec authored by Jorge Canizales's avatar Jorge Canizales
Browse files

Subclass GRXWriter instead of conforming to protocol

parent 739c9987
No related branches found
No related tags found
No related merge requests found
...@@ -52,7 +52,7 @@ ...@@ -52,7 +52,7 @@
extern id const kGRPCStatusMetadataKey; extern id const kGRPCStatusMetadataKey;
// Represents a single gRPC remote call. // Represents a single gRPC remote call.
@interface GRPCCall : NSObject<GRXWriter> @interface GRPCCall : GRXWriter
// These HTTP headers will be passed to the server as part of this call. Each HTTP header is a // These HTTP headers will be passed to the server as part of this call. Each HTTP header is a
// name-value pair with string names and either string or binary values. // name-value pair with string names and either string or binary values.
......
...@@ -33,8 +33,9 @@ ...@@ -33,8 +33,9 @@
#import <Foundation/Foundation.h> #import <Foundation/Foundation.h>
#import <RxLibrary/GRXWriter.h>
@protocol GRXWriteable; @protocol GRXWriteable;
@protocol GRXWriter;
// This is a thread-safe wrapper over a GRXWriteable instance. It lets one // This is a thread-safe wrapper over a GRXWriteable instance. It lets one
// enqueue calls to a GRXWriteable instance for the main thread, guaranteeing // enqueue calls to a GRXWriteable instance for the main thread, guaranteeing
......
...@@ -51,7 +51,7 @@ ...@@ -51,7 +51,7 @@
// pipe will keep buffering all data written to it, your application could run out of memory and // pipe will keep buffering all data written to it, your application could run out of memory and
// crash. If you want to react to flow control signals to prevent that, instead of using this class // crash. If you want to react to flow control signals to prevent that, instead of using this class
// you can implement an object that conforms to GRXWriter. // you can implement an object that conforms to GRXWriter.
@interface GRXBufferedPipe : NSObject<GRXWriteable, GRXWriter> @interface GRXBufferedPipe : GRXWriter<GRXWriteable>
// Convenience constructor. // Convenience constructor.
+ (instancetype)pipe; + (instancetype)pipe;
......
...@@ -40,7 +40,7 @@ ...@@ -40,7 +40,7 @@
// //
// Unless the writeable callback pauses them or stops them early, these writers will do all their // Unless the writeable callback pauses them or stops them early, these writers will do all their
// interactions with the writeable before the start method returns. // interactions with the writeable before the start method returns.
@interface GRXImmediateWriter : NSObject<GRXWriter> @interface GRXImmediateWriter : GRXWriter
// Returns a writer that pulls values from the passed NSEnumerator instance and pushes them to // Returns a writer that pulls values from the passed NSEnumerator instance and pushes them to
// its writeable. The NSEnumerator is released when it finishes. // its writeable. The NSEnumerator is released when it finishes.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment