(next connect.StreamingHandlerFunc)
| 839 | } |
| 840 | |
| 841 | func (a *assertPeerInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc { |
| 842 | return func(ctx context.Context, conn connect.StreamingHandlerConn) error { |
| 843 | assert.NotZero(a.tb, conn.Peer().Addr) |
| 844 | assert.NotZero(a.tb, conn.Peer().Protocol) |
| 845 | assert.NotZero(a.tb, conn.Spec()) |
| 846 | return next(ctx, conn) |
| 847 | } |
| 848 | } |
| 849 | |
| 850 | type assertSchemaInterceptor struct { |
| 851 | tb testing.TB |