19 #import <Foundation/Foundation.h>
41 - (instancetype)initWithWriteable:(
id<
GRXWriteable>)writeable
42 dispatchQueue:(dispatch_queue_t)queue NS_DESIGNATED_INITIALIZER;
43 - (instancetype)initWithWriteable:(
id<
GRXWriteable>)writeable;
49 - (void)enqueueValue:(
id)value completionHandler:(
void (^)(
void))handler;
64 - (void)cancelWithError:(NSError *)error;
This is a thread-safe wrapper over a GRXWriteable instance.
Definition: GRXConcurrentWriteable.h:35
void enqueueSuccessfulCompletion()
Enqueues writesFinishedWithError:nil to be sent to the writeable in the designated dispatch queue.
void cancelSilently()
Cancels all pending messages to the writeable enqueued by this object (both past and future).
Utility to create objects that conform to the GRXWriteable protocol, from blocks that handle each of ...
Definition: GRXWriteable.h:47