Package io.smallrye.reactive.messaging.gcp.pubsub

Class PubSubSource

java.lang.Object

io.smallrye.reactive.messaging.gcp.pubsub.PubSubSource

All Implemented Interfaces:

Consumer<io.smallrye.mutiny.subscription.MultiEmitter<? super Message<?>>>

public class PubSubSource
extends Object
implements Consumer<io.smallrye.mutiny.subscription.MultiEmitter<? super Message<?>>>

Constructor Summary

Constructors

Constructor	Description
PubSubSource(PubSubConfig config, PubSubManager manager)

Method Summary

Modifier and Type	Method	Description
void	accept(io.smallrye.mutiny.subscription.MultiEmitter<? super Message<?>> emitter)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

PubSubSource

public PubSubSource(PubSubConfig config,
                    PubSubManager manager)

Method Detail

accept

public void accept(io.smallrye.mutiny.subscription.MultiEmitter<? super Message<?>> emitter)

Specified by:

accept in interface Consumer<io.smallrye.mutiny.subscription.MultiEmitter<? super Message<?>>>