Method Send

aibridge/intercept/eventstream/eventstream.go:165–178

Send enqueues an event in a non-blocking fashion, but if the channel is full then it will block.

(ctx context.Context, payload []byte)

// Send enqueues an event in a non-blocking fashion, but if the channel is full
// then it will block.
func (s *EventStream) Send(ctx context.Context, payload []byte) error {
	// Save an unnecessary marshaling if possible.
	select {
	case <-ctx.Done():
		return ctx.Err()
	case <-s.ctx.Done():
		return s.ctx.Err()
	case <-s.doneCh:
		return ErrEventStreamClosed
	default:
	}

	return s.SendRaw(ctx, payload)
}

func (s *EventStream) SendRaw(ctx context.Context, payload []byte) error {
	select {