Fix CloseAndRecv
for patch streamer #1662
1 changed files with 3 additions and 0 deletions
|
@ -214,6 +214,9 @@ func (s *Streamer) Send(ctx context.Context, req *objectV2.PatchRequest) error {
|
|||
}
|
||||
|
||||
func (s *Streamer) CloseAndRecv(ctx context.Context) (*objectV2.PatchResponse, error) {
|
||||
if s.patcher == nil {
|
||||
return nil, errors.New("uninitialized patch streamer")
|
||||
}
|
||||
patcherResp, err := s.patcher.Close(ctx)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
Loading…
Add table
Reference in a new issue