api_stream_dial.go

package bifrost_api

import (
	stream_api "github.com/aperturerobotics/bifrost/stream/api"
	stream_api_dial "github.com/aperturerobotics/bifrost/stream/api/dial"
)

// DialStream dials a outgoing stream.
// Stream data is sent over the request / response streams.
func (a *API) DialStream(serv stream_api.SRPCStreamService_DialStreamStream) error {
	ctx := serv.Context()
	msg, err := serv.Recv()
	if err != nil {
		return err
	}

	conf := msg.GetConfig()
	if err := conf.Validate(); err != nil {
		return err
	}

	return stream_api_dial.ProcessRPC(
		ctx,
		a.bus,
		conf,
		stream_api.NewDialServerRPC(serv),
	)
}