Skip to content

Commit d6043ef

Browse files
SarahFrenchradeksimko
authored andcommitted
Update WriteStateBytesStreamMsg => WriteStateBytesChunk
1 parent fb4c1fc commit d6043ef

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

tfprotov6/tf6server/server.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1644,7 +1644,7 @@ func (s *server) WriteStateBytes(srv grpc.ClientStreamingServer[tfplugin6.WriteS
16441644
return err
16451645
}
16461646

1647-
iterator := func(yield func(tfprotov6.WriteStateBytesStreamMsg) bool) {
1647+
iterator := func(yield func(tfprotov6.WriteStateBytesChunk) bool) {
16481648
for {
16491649
chunk, err := srv.Recv()
16501650
if err == io.EOF {
@@ -1658,8 +1658,8 @@ func (s *server) WriteStateBytes(srv grpc.ClientStreamingServer[tfplugin6.WriteS
16581658
}
16591659

16601660
ok := yield(
1661-
tfprotov6.WriteStateBytesStreamMsg{
1662-
Chunk: tfprotov6.WriteStateByteChunk{
1661+
tfprotov6.WriteStateBytesChunk{
1662+
StateByteChunk: tfprotov6.StateByteChunk{
16631663
Bytes: chunk.Bytes,
16641664
TotalLength: chunk.TotalLength,
16651665
Range: tfprotov6.StateByteRange{
@@ -1676,7 +1676,7 @@ func (s *server) WriteStateBytes(srv grpc.ClientStreamingServer[tfplugin6.WriteS
16761676
}
16771677

16781678
resp, err := server.WriteStateBytes(ctx, &tfprotov6.WriteStateBytesStream{
1679-
Messages: iterator,
1679+
Chunks: iterator,
16801680
})
16811681
if err != nil {
16821682
return err

0 commit comments

Comments
 (0)