// SubscribeStream is called when a client wants to connect to a stream. This callback
// allows sending the first message.
SubscribeStream is called when a client wants to connect to a stream. This callback
allows sending the first message.
// SubscribeStream is called when a client wants to connect to a stream . This callback // allows sending the first message .
func (d *CouchbaseDatasource) SubscribeStream(c context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error) {
	log.DefaultLogger.Info("SubscribeStream called", "request", req)
  status := backend.SubscribeStreamStatusOK
	return &backend.SubscribeStreamResponse{
		Status: status,
	}, nil
}
func ( d * CouchbaseDatasource ) SubscribeStream ( c context . Context , req * backend . SubscribeStreamRequest ) ( * backend . SubscribeStreamResponse , error ) { log . DefaultLogger . Info ( " " , " " , req ) status := backend . SubscribeStreamStatusOK return & backend . SubscribeStreamResponse { Status : status , } , nil }
SubscribeStream is called when a client wants to connect to a stream.
SubscribeStream is called when a client wants to connect to a stream .