class TaskBasedSignalOffloader implements SignalOffloader {

    @Override
    public <T> SingleSource.Subscriber<? super T> offloadCancellable(
            final SingleSource.Subscriber<? super T> subscriber) {
        return new OffloadedCancellableSingleSubscriber<>(subscriber, executor);
    }

      TaskBasedSignalOffloader(final Executor executor);
      TaskBasedSignalOffloader(final Executor executor, final int publisherSignalQueueInitialCapacity);

}