(parts []fantasy.ObjectStreamPart)
| 928 | } |
| 929 | |
| 930 | func objectPartsToSeq(parts []fantasy.ObjectStreamPart) fantasy.ObjectStreamResponse { |
| 931 | return func(yield func(fantasy.ObjectStreamPart) bool) { |
| 932 | for _, part := range parts { |
| 933 | if !yield(part) { |
| 934 | return |
| 935 | } |
| 936 | } |
| 937 | } |
| 938 | } |
| 939 | |
| 940 | func partsToSeq(parts []fantasy.StreamPart) fantasy.StreamResponse { |
| 941 | return func(yield func(fantasy.StreamPart) bool) { |
no outgoing calls
no test coverage detected