File tree Expand file tree Collapse file tree 1 file changed +0
-12
lines changed
examples/go/streams-client Expand file tree Collapse file tree 1 file changed +0
-12
lines changed Original file line number Diff line number Diff line change @@ -31,12 +31,6 @@ type ThrottleStream[T any] struct {
31
31
values []T
32
32
}
33
33
34
- func (s * ThrottleStream [T ]) IsComplete () bool {
35
- // The stream has full contents available in `s.values`,
36
- // but we return `false` to force async transmission
37
- return false
38
- }
39
-
40
34
func (s * ThrottleStream [T ]) Receive () ([]T , error ) {
41
35
if len (s .values ) == 0 {
42
36
return nil , io .EOF
@@ -52,12 +46,6 @@ type ThrottleReader struct {
52
46
buf []byte
53
47
}
54
48
55
- func (s * ThrottleReader ) IsComplete () bool {
56
- // The reader has full contents available in `s.buf`,
57
- // but we return `false` to force async transmission
58
- return false
59
- }
60
-
61
49
func (s * ThrottleReader ) Read (p []byte ) (int , error ) {
62
50
if len (s .buf ) == 0 {
63
51
return 0 , io .EOF
You can’t perform that action at this time.
0 commit comments