Moved SwitchableInputStream and its test class to org.jboss.netty.handler.codec.serialization because it's used only there.
This commit is contained in:
parent
4d9b3346c5
commit
a36ea0f3a4
@ -25,7 +25,6 @@ import org.jboss.netty.buffer.ChannelBufferInputStream;
|
|||||||
import org.jboss.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
import org.jboss.netty.channel.ChannelHandlerContext;
|
import org.jboss.netty.channel.ChannelHandlerContext;
|
||||||
import org.jboss.netty.handler.codec.replay.ReplayingDecoder;
|
import org.jboss.netty.handler.codec.replay.ReplayingDecoder;
|
||||||
import org.jboss.netty.util.internal.SwitchableInputStream;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A decoder which deserializes the received {@link ChannelBuffer}s into Java
|
* A decoder which deserializes the received {@link ChannelBuffer}s into Java
|
||||||
|
@ -13,7 +13,7 @@
|
|||||||
* License for the specific language governing permissions and limitations
|
* License for the specific language governing permissions and limitations
|
||||||
* under the License.
|
* under the License.
|
||||||
*/
|
*/
|
||||||
package org.jboss.netty.util.internal;
|
package org.jboss.netty.handler.codec.serialization;
|
||||||
|
|
||||||
import java.io.FilterInputStream;
|
import java.io.FilterInputStream;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
@ -28,13 +28,13 @@ import java.io.InputStream;
|
|||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
public class SwitchableInputStream extends FilterInputStream {
|
final class SwitchableInputStream extends FilterInputStream {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new instance without initializing the reference to the
|
* Creates a new instance without initializing the reference to the
|
||||||
* underlying stream.
|
* underlying stream.
|
||||||
*/
|
*/
|
||||||
public SwitchableInputStream() {
|
SwitchableInputStream() {
|
||||||
super(null);
|
super(null);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -42,7 +42,7 @@ public class SwitchableInputStream extends FilterInputStream {
|
|||||||
* Creates a new instance with the initial reference to the underlying
|
* Creates a new instance with the initial reference to the underlying
|
||||||
* stream.
|
* stream.
|
||||||
*/
|
*/
|
||||||
public void switchStream(InputStream in) {
|
void switchStream(InputStream in) {
|
||||||
this.in = in;
|
this.in = in;
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -13,7 +13,7 @@
|
|||||||
* License for the specific language governing permissions and limitations
|
* License for the specific language governing permissions and limitations
|
||||||
* under the License.
|
* under the License.
|
||||||
*/
|
*/
|
||||||
package org.jboss.netty.util.internal;
|
package org.jboss.netty.handler.codec.serialization;
|
||||||
|
|
||||||
import static org.easymock.EasyMock.*;
|
import static org.easymock.EasyMock.*;
|
||||||
import static org.easymock.classextension.EasyMock.*;
|
import static org.easymock.classextension.EasyMock.*;
|
||||||
@ -21,6 +21,7 @@ import static org.junit.Assert.*;
|
|||||||
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
|
|
||||||
|
import org.jboss.netty.handler.codec.serialization.SwitchableInputStream;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
|
|
Loading…
x
Reference in New Issue
Block a user