Package com.pulumi.automation.events.internal

Class EventsServer

java.lang.Object

pulumirpc.EventsGrpc.EventsImplBase

com.pulumi.automation.events.internal.EventsServer

All Implemented Interfaces:

io.grpc.BindableService, pulumirpc.EventsGrpc.AsyncService

@InternalUse
public class EventsServer
extends pulumirpc.EventsGrpc.EventsImplBase

gRPC server implementation for receiving engine events from the Pulumi engine. This server implements the Events service defined in events.proto.

Constructor Summary

Constructors

Constructor	Description
EventsServer(Consumer<EngineEvent> onEvent)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	getCompletionFuture()	Return a future that completes when the event stream is finished.
io.grpc.stub.StreamObserver<pulumirpc.EventsOuterClass.EventRequest>	streamEvents(io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

Methods inherited from class pulumirpc.EventsGrpc.EventsImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Details

EventsServer

public EventsServer(Consumer<EngineEvent> onEvent)

Method Details

getCompletionFuture

public CompletableFuture<Void> getCompletionFuture()

Return a future that completes when the event stream is finished.

Returns:

CompletableFuture that completes when the stream ends

streamEvents

public io.grpc.stub.StreamObserver<pulumirpc.EventsOuterClass.EventRequest> streamEvents(io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)