Method Drain

pkg/runtime/message_queue.go:35–35

Drain returns all pending messages and removes them from the queue. Must not block — if the queue is empty it returns nil.

(ctx context.Context)

	// Drain returns all pending messages and removes them from the queue.
	// Must not block — if the queue is empty it returns nil.
	Drain(ctx context.Context) []QueuedMessage
}

// inMemoryMessageQueue is the default MessageQueue backed by a buffered channel.