diff options
Diffstat (limited to 'connection_streams_controller.go')
| -rw-r--r-- | connection_streams_controller.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/connection_streams_controller.go b/connection_streams_controller.go index 038c2c5..d55c2fd 100644 --- a/connection_streams_controller.go +++ b/connection_streams_controller.go @@ -179,7 +179,7 @@ func (csc ConnectionStreamsController) GetConnectionMessages(c context.Context, var isMetadataContinuation bool for _, elem := range messagesBuffer { elem.Metadata = metadata - elem.IsMetadataContinuation = isMetadataContinuation + elem.IsMetadataContinuation = metadata != nil && isMetadataContinuation isMetadataContinuation = true } |