com.linkedin.r2.testutils.filter

Class StreamCountFilter

java.lang.Object

com.linkedin.r2.testutils.filter.StreamCountFilter

All Implemented Interfaces:

com.linkedin.r2.filter.message.stream.StreamFilter

public class StreamCountFilter
extends java.lang.Object
implements com.linkedin.r2.filter.message.stream.StreamFilter

Constructor Summary

Constructors

Constructor and Description
StreamCountFilter()

Method Summary

Methods

Modifier and Type	Method and Description
int	getStreamErrCount()
int	getStreamReqCount()
int	getStreamResCount()
void	onStreamError(java.lang.Throwable ex, com.linkedin.r2.message.RequestContext requestContext, java.util.Map<java.lang.String,java.lang.String> wireAttrs, com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter)
void	onStreamRequest(com.linkedin.r2.message.stream.StreamRequest req, com.linkedin.r2.message.RequestContext requestContext, java.util.Map<java.lang.String,java.lang.String> wireAttrs, com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter)
void	onStreamResponse(com.linkedin.r2.message.stream.StreamResponse res, com.linkedin.r2.message.RequestContext requestContext, java.util.Map<java.lang.String,java.lang.String> wireAttrs, com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter)
void	reset()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamCountFilter

public StreamCountFilter()

Method Detail

getStreamReqCount

public int getStreamReqCount()

getStreamResCount

public int getStreamResCount()

getStreamErrCount

public int getStreamErrCount()

reset

public void reset()

onStreamRequest

public void onStreamRequest(com.linkedin.r2.message.stream.StreamRequest req,
                   com.linkedin.r2.message.RequestContext requestContext,
                   java.util.Map<java.lang.String,java.lang.String> wireAttrs,
                   com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter)

Specified by:

onStreamRequest in interface com.linkedin.r2.filter.message.stream.StreamFilter

onStreamResponse

public void onStreamResponse(com.linkedin.r2.message.stream.StreamResponse res,
                    com.linkedin.r2.message.RequestContext requestContext,
                    java.util.Map<java.lang.String,java.lang.String> wireAttrs,
                    com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter)

Specified by:

onStreamResponse in interface com.linkedin.r2.filter.message.stream.StreamFilter

onStreamError

public void onStreamError(java.lang.Throwable ex,
                 com.linkedin.r2.message.RequestContext requestContext,
                 java.util.Map<java.lang.String,java.lang.String> wireAttrs,
                 com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter)

Specified by:

onStreamError in interface com.linkedin.r2.filter.message.stream.StreamFilter