class FromInputStreamPublisher extends Publisher<byte[]> implements PublisherSource<byte[]> {

    @Override
    public void subscribe(final Subscriber<? super byte[]> subscriber) {
        subscribeInternal(subscriber);
    }

      FromInputStreamPublisher(final InputStream stream);

}