Home | History | Annotate | Download | only in RxLibrary
      1 /*
      2  *
      3  * Copyright 2015 gRPC authors.
      4  *
      5  * Licensed under the Apache License, Version 2.0 (the "License");
      6  * you may not use this file except in compliance with the License.
      7  * You may obtain a copy of the License at
      8  *
      9  *     http://www.apache.org/licenses/LICENSE-2.0
     10  *
     11  * Unless required by applicable law or agreed to in writing, software
     12  * distributed under the License is distributed on an "AS IS" BASIS,
     13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     14  * See the License for the specific language governing permissions and
     15  * limitations under the License.
     16  *
     17  */
     18 
     19 #import "GRXWriter.h"
     20 
     21 /**
     22  * A "proxy" class that simply forwards values, completion, and errors from its input writer to its
     23  * writeable.
     24  * It is useful as a superclass for pipes that act as a transformation of their
     25  * input writer, and for classes that represent objects with input and
     26  * output sequences of values, like an RPC.
     27  *
     28  * Thread-safety:
     29  * All messages sent to this object need to be serialized. When it is started, the writer it wraps
     30  * is started in the same thread. Manual state changes are propagated to the wrapped writer in the
     31  * same thread too. Importantly, all messages the wrapped writer sends to its writeable need to be
     32  * serialized with any message sent to this object.
     33  */
     34 @interface GRXForwardingWriter : GRXWriter
     35 - (instancetype)initWithWriter:(GRXWriter *)writer NS_DESIGNATED_INITIALIZER;
     36 @end
     37