Skip to content

Commit d7e9242

Browse files
committed
UploadResponse now has 'oneof' clause for better API design
1 parent 246adf9 commit d7e9242

File tree

3 files changed

+171
-130
lines changed

3 files changed

+171
-130
lines changed

commands/daemon/daemon.go

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -297,8 +297,16 @@ func (s *ArduinoCoreServerImpl) PlatformList(ctx context.Context, req *rpc.Platf
297297
// Upload FIXMEDOC
298298
func (s *ArduinoCoreServerImpl) Upload(req *rpc.UploadRequest, stream rpc.ArduinoCoreService_UploadServer) error {
299299
syncSend := NewSynchronizedSend(stream.Send)
300-
outStream := feedStreamTo(func(data []byte) { syncSend.Send(&rpc.UploadResponse{OutStream: data}) })
301-
errStream := feedStreamTo(func(data []byte) { syncSend.Send(&rpc.UploadResponse{ErrStream: data}) })
300+
outStream := feedStreamTo(func(data []byte) {
301+
syncSend.Send(&rpc.UploadResponse{
302+
Message: &rpc.UploadResponse_OutStream{OutStream: data},
303+
})
304+
})
305+
errStream := feedStreamTo(func(data []byte) {
306+
syncSend.Send(&rpc.UploadResponse{
307+
Message: &rpc.UploadResponse_ErrStream{ErrStream: data},
308+
})
309+
})
302310
err := upload.Upload(stream.Context(), req, outStream, errStream)
303311
outStream.Close()
304312
errStream.Close()

0 commit comments

Comments
 (0)