|Modifier and Type||Method and Description|
public static SdkPublisher<ByteBuffer> envelopeWrappedPublisher(org.reactivestreams.Publisher<ByteBuffer> publisher, String envelopePrefix, String envelopeSuffix)
SdkPublisherthat wraps a
ByteBufferpublisher and inserts additional content that wraps the published content like an envelope. This can be used when you want to transform the content of an asynchronous SDK response by putting it in an envelope. This publisher implementation does not comply with the complete flow spec (as it inserts data into the middle of a flow between a third-party publisher and subscriber rather than acting as a fully featured independent publisher) and therefore should only be used in a limited fashion when we have complete control over how data is being published to the publisher it wraps.
publisher- The underlying publisher to wrap the content of.
envelopePrefix- A string representing the content to be inserted as the head of the containing envelope.
envelopeSuffix- A string representing the content to be inserted as the tail of containing envelope.
SdkPublisherthat wraps the provided publisher.
Copyright © 2020 Amazon Web Services, Inc. All Rights Reserved.