code: public <T> Observable<Notification<T>> channel(
          final DeliveryMethod type,
          final ObservableFactoryNoArg<T> observableFactoryNoArg) {
  
          return channel(type, new Func1<Object, Observable<Notification<T>>>() {
              @Override
              public Observable<Notification<T>> call(Object ignored) {
                  return ReconnectableMap.INSTANCE.channel(key, type, observableFactoryNoArg);
              }
          });
      }
docs: Provides a channel to an observable that can be created with a given observable factory.
  
  @param type                   a type of the channel.
  @param observableFactoryNoArg an observable factory which will be used to create an observable per launch.
  @return an observable which emits {@link rx.Notification} of onNext and onError observable emissions.