move websocket-core-common messages and util packages out of internal
Signed-off-by: Lachlan Roberts <lachlan@webtide.com>
This commit is contained in:
parent
e5b313e379
commit
cc40a545dc
|
@ -21,53 +21,11 @@ module org.eclipse.jetty.websocket.core.common
|
|||
|
||||
exports org.eclipse.jetty.websocket.core;
|
||||
exports org.eclipse.jetty.websocket.core.exception;
|
||||
|
||||
exports org.eclipse.jetty.websocket.core.messages;
|
||||
exports org.eclipse.jetty.websocket.core.util;
|
||||
exports org.eclipse.jetty.websocket.core.internal to
|
||||
org.eclipse.jetty.websocket.core.client,
|
||||
org.eclipse.jetty.websocket.core.server,
|
||||
org.eclipse.jetty.util; // Export to DecoratedObjectFactory.
|
||||
|
||||
// The Jetty & Jakarta API Layers need to access both access some internal utilities which we don't want to expose.
|
||||
exports org.eclipse.jetty.websocket.core.internal.util to
|
||||
org.eclipse.jetty.ee8.websocket.jetty.common,
|
||||
org.eclipse.jetty.ee8.websocket.jetty.client,
|
||||
org.eclipse.jetty.ee8.websocket.jetty.server,
|
||||
org.eclipse.jetty.ee8.websocket.javax.common,
|
||||
org.eclipse.jetty.ee8.websocket.javax.client,
|
||||
org.eclipse.jetty.ee8.websocket.javax.server,
|
||||
org.eclipse.jetty.ee9.websocket.jetty.common,
|
||||
org.eclipse.jetty.ee9.websocket.jetty.client,
|
||||
org.eclipse.jetty.ee9.websocket.jetty.server,
|
||||
org.eclipse.jetty.ee9.websocket.jakarta.common,
|
||||
org.eclipse.jetty.ee9.websocket.jakarta.client,
|
||||
org.eclipse.jetty.ee9.websocket.jakarta.server,
|
||||
org.eclipse.jetty.ee10.websocket.jetty.common,
|
||||
org.eclipse.jetty.ee10.websocket.jetty.client,
|
||||
org.eclipse.jetty.ee10.websocket.jetty.server,
|
||||
org.eclipse.jetty.ee10.websocket.jakarta.common,
|
||||
org.eclipse.jetty.ee10.websocket.jakarta.client,
|
||||
org.eclipse.jetty.ee10.websocket.jakarta.server;
|
||||
|
||||
exports org.eclipse.jetty.websocket.core.internal.messages to
|
||||
org.eclipse.jetty.ee8.websocket.jetty.common,
|
||||
org.eclipse.jetty.ee8.websocket.jetty.client,
|
||||
org.eclipse.jetty.ee8.websocket.jetty.server,
|
||||
org.eclipse.jetty.ee8.websocket.javax.common,
|
||||
org.eclipse.jetty.ee8.websocket.javax.client,
|
||||
org.eclipse.jetty.ee8.websocket.javax.server,
|
||||
org.eclipse.jetty.ee9.websocket.jetty.common,
|
||||
org.eclipse.jetty.ee9.websocket.jetty.client,
|
||||
org.eclipse.jetty.ee9.websocket.jetty.server,
|
||||
org.eclipse.jetty.ee9.websocket.jakarta.common,
|
||||
org.eclipse.jetty.ee9.websocket.jakarta.client,
|
||||
org.eclipse.jetty.ee9.websocket.jakarta.server,
|
||||
org.eclipse.jetty.ee10.websocket.jetty.common,
|
||||
org.eclipse.jetty.ee10.websocket.jetty.client,
|
||||
org.eclipse.jetty.ee10.websocket.jetty.server,
|
||||
org.eclipse.jetty.ee10.websocket.jakarta.common,
|
||||
org.eclipse.jetty.ee10.websocket.jakarta.client,
|
||||
org.eclipse.jetty.ee10.websocket.jakarta.server;
|
||||
|
||||
uses org.eclipse.jetty.websocket.core.Extension;
|
||||
|
||||
provides org.eclipse.jetty.websocket.core.Extension with
|
||||
|
|
|
@ -16,7 +16,7 @@ package org.eclipse.jetty.websocket.core.exception;
|
|||
import java.lang.annotation.Annotation;
|
||||
import java.lang.reflect.Method;
|
||||
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
|
||||
@SuppressWarnings("serial")
|
||||
public class DuplicateAnnotationException extends InvalidWebSocketException
|
||||
|
|
|
@ -17,7 +17,7 @@ import java.lang.annotation.Annotation;
|
|||
import java.lang.invoke.MethodType;
|
||||
import java.lang.reflect.Method;
|
||||
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
|
||||
@SuppressWarnings("serial")
|
||||
public class InvalidSignatureException extends InvalidWebSocketException
|
||||
|
|
|
@ -21,7 +21,7 @@ import org.eclipse.jetty.websocket.core.ExtensionConfig;
|
|||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
||||
import org.eclipse.jetty.websocket.core.exception.ProtocolException;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.FrameValidation;
|
||||
import org.eclipse.jetty.websocket.core.util.FrameValidation;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -46,7 +46,7 @@ import org.eclipse.jetty.websocket.core.exception.CloseException;
|
|||
import org.eclipse.jetty.websocket.core.exception.ProtocolException;
|
||||
import org.eclipse.jetty.websocket.core.exception.WebSocketTimeoutException;
|
||||
import org.eclipse.jetty.websocket.core.exception.WebSocketWriteTimeoutException;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.FrameValidation;
|
||||
import org.eclipse.jetty.websocket.core.util.FrameValidation;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.lang.invoke.MethodHandle;
|
||||
import java.util.Objects;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.lang.invoke.MethodHandle;
|
||||
import java.lang.invoke.MethodType;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.lang.invoke.MethodHandle;
|
||||
import java.lang.invoke.MethodType;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.io.Closeable;
|
||||
import java.lang.invoke.MethodHandle;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.lang.invoke.MethodHandle;
|
||||
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.OutputStream;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.Reader;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import org.eclipse.jetty.util.Callback;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.Writer;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.lang.invoke.MethodHandle;
|
||||
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.lang.invoke.MethodHandle;
|
||||
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.lang.invoke.MethodHandle;
|
||||
import java.util.Objects;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.lang.invoke.MethodHandle;
|
||||
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.messages;
|
||||
package org.eclipse.jetty.websocket.core.messages;
|
||||
|
||||
import java.lang.invoke.MethodHandle;
|
||||
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.util;
|
||||
package org.eclipse.jetty.websocket.core.util;
|
||||
|
||||
import org.eclipse.jetty.websocket.core.Behavior;
|
||||
import org.eclipse.jetty.websocket.core.CloseStatus;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.util;
|
||||
package org.eclipse.jetty.websocket.core.util;
|
||||
|
||||
import java.lang.invoke.MethodHandle;
|
||||
import java.lang.invoke.MethodHandles;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.util;
|
||||
package org.eclipse.jetty.websocket.core.util;
|
||||
|
||||
import java.lang.annotation.Annotation;
|
||||
import java.lang.invoke.MethodType;
|
|
@ -11,7 +11,7 @@
|
|||
// ========================================================================
|
||||
//
|
||||
|
||||
package org.eclipse.jetty.websocket.core.internal.util;
|
||||
package org.eclipse.jetty.websocket.core.util;
|
||||
|
||||
/**
|
||||
* Collection of utility methods for Text content
|
|
@ -23,7 +23,7 @@ import org.eclipse.jetty.websocket.core.internal.ExtensionStack;
|
|||
import org.eclipse.jetty.websocket.core.internal.Generator;
|
||||
import org.eclipse.jetty.websocket.core.internal.Negotiated;
|
||||
import org.eclipse.jetty.websocket.core.internal.WebSocketCoreSession;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.FrameValidation;
|
||||
import org.eclipse.jetty.websocket.core.util.FrameValidation;
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.provider.Arguments;
|
||||
import org.junit.jupiter.params.provider.MethodSource;
|
||||
|
|
|
@ -29,7 +29,7 @@ import org.eclipse.jetty.websocket.core.internal.ExtensionStack;
|
|||
import org.eclipse.jetty.websocket.core.internal.Generator;
|
||||
import org.eclipse.jetty.websocket.core.internal.Negotiated;
|
||||
import org.eclipse.jetty.websocket.core.internal.WebSocketCoreSession;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.FrameValidation;
|
||||
import org.eclipse.jetty.websocket.core.util.FrameValidation;
|
||||
import org.hamcrest.Matchers;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.slf4j.Logger;
|
||||
|
|
|
@ -22,7 +22,7 @@ import org.eclipse.jetty.websocket.core.internal.ExtensionStack;
|
|||
import org.eclipse.jetty.websocket.core.internal.Negotiated;
|
||||
import org.eclipse.jetty.websocket.core.internal.Parser;
|
||||
import org.eclipse.jetty.websocket.core.internal.WebSocketCoreSession;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.FrameValidation;
|
||||
import org.eclipse.jetty.websocket.core.util.FrameValidation;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.is;
|
||||
|
|
|
@ -26,7 +26,7 @@ import org.eclipse.jetty.util.IO;
|
|||
import org.eclipse.jetty.util.StringUtil;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageReader;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageReader;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.eclipse.jetty.util.Utf8StringBuilder;
|
|||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageWriter;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageWriter;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -29,7 +29,7 @@ import org.eclipse.jetty.util.Utf8Appendable;
|
|||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialStringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialStringMessageSink;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.eclipse.jetty.websocket.core.CoreSession;
|
|||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.exception.MessageTooLargeException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.StringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.StringMessageSink;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -18,7 +18,7 @@ import jakarta.websocket.EndpointConfig;
|
|||
import org.eclipse.jetty.ee10.websocket.jakarta.common.JakartaWebSocketContainer;
|
||||
import org.eclipse.jetty.ee10.websocket.jakarta.common.JakartaWebSocketFrameHandlerFactory;
|
||||
import org.eclipse.jetty.ee10.websocket.jakarta.common.JakartaWebSocketFrameHandlerMetadata;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
|
||||
public class JakartaWebSocketClientFrameHandlerFactory extends JakartaWebSocketFrameHandlerFactory
|
||||
{
|
||||
|
|
|
@ -26,9 +26,9 @@ import org.eclipse.jetty.util.FutureCallback;
|
|||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageOutputStream;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageWriter;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.TextUtils;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageOutputStream;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageWriter;
|
||||
import org.eclipse.jetty.websocket.core.util.TextUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -25,7 +25,7 @@ import org.eclipse.jetty.util.FutureCallback;
|
|||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.TextUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.TextUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -46,11 +46,11 @@ import org.eclipse.jetty.websocket.core.FrameHandler;
|
|||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.exception.ProtocolException;
|
||||
import org.eclipse.jetty.websocket.core.exception.WebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialStringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialStringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -47,12 +47,12 @@ import org.eclipse.jetty.websocket.core.CoreSession;
|
|||
import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidWebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialStringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialStringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
|
||||
public abstract class JakartaWebSocketFrameHandlerFactory
|
||||
{
|
||||
|
|
|
@ -17,7 +17,7 @@ import java.lang.invoke.MethodHandle;
|
|||
import java.util.List;
|
||||
|
||||
import org.eclipse.jetty.ee10.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
|
||||
public class JakartaWebSocketMessageMetadata
|
||||
{
|
||||
|
|
|
@ -28,8 +28,8 @@ import org.eclipse.jetty.websocket.core.Frame;
|
|||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.OutgoingFrames;
|
||||
import org.eclipse.jetty.websocket.core.exception.WebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageOutputStream;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageWriter;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageOutputStream;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageWriter;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -38,7 +38,7 @@ import org.eclipse.jetty.ee10.websocket.jakarta.common.encoders.AvailableEncoder
|
|||
import org.eclipse.jetty.util.Callback;
|
||||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.ExtensionConfig;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -29,7 +29,7 @@ import jakarta.websocket.EndpointConfig;
|
|||
import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidWebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
|
||||
public class AvailableDecoders implements Iterable<RegisteredDecoder>, Closeable
|
||||
{
|
||||
|
|
|
@ -29,7 +29,7 @@ import org.eclipse.jetty.ee10.websocket.jakarta.common.InitException;
|
|||
import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidWebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -24,7 +24,7 @@ import org.eclipse.jetty.util.Callback;
|
|||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.exception.CloseException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -25,8 +25,8 @@ import org.eclipse.jetty.ee10.websocket.jakarta.common.JakartaWebSocketFrameHand
|
|||
import org.eclipse.jetty.ee10.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.exception.CloseException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.ByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -26,8 +26,8 @@ import org.eclipse.jetty.ee10.websocket.jakarta.common.JakartaWebSocketFrameHand
|
|||
import org.eclipse.jetty.ee10.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.exception.CloseException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.InputStreamMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.InputStreamMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
|
||||
public class DecodedBinaryStreamMessageSink<T> extends AbstractDecodedMessageSink.Stream<Decoder.BinaryStream<T>>
|
||||
{
|
||||
|
|
|
@ -24,8 +24,8 @@ import org.eclipse.jetty.ee10.websocket.jakarta.common.JakartaWebSocketFrameHand
|
|||
import org.eclipse.jetty.ee10.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.exception.CloseException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.StringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.StringMessageSink;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -26,8 +26,8 @@ import org.eclipse.jetty.ee10.websocket.jakarta.common.JakartaWebSocketFrameHand
|
|||
import org.eclipse.jetty.ee10.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.exception.CloseException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ReaderMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.ReaderMessageSink;
|
||||
|
||||
public class DecodedTextStreamMessageSink<T> extends AbstractDecodedMessageSink.Stream<Decoder.TextStream<T>>
|
||||
{
|
||||
|
|
|
@ -16,7 +16,7 @@ package org.eclipse.jetty.ee10.websocket.jakarta.common;
|
|||
import jakarta.websocket.ClientEndpoint;
|
||||
import jakarta.websocket.ClientEndpointConfig;
|
||||
import jakarta.websocket.EndpointConfig;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
|
||||
public class DummyFrameHandlerFactory extends JakartaWebSocketFrameHandlerFactory
|
||||
{
|
||||
|
|
|
@ -32,7 +32,7 @@ import org.eclipse.jetty.util.FutureCallback;
|
|||
import org.eclipse.jetty.util.IO;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.InputStreamMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.InputStreamMessageSink;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static java.nio.charset.StandardCharsets.UTF_8;
|
||||
|
|
|
@ -26,7 +26,7 @@ import org.eclipse.jetty.util.Utf8StringBuilder;
|
|||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageWriter;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageWriter;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.eclipse.jetty.util.FutureCallback;
|
|||
import org.eclipse.jetty.util.IO;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ReaderMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.ReaderMessageSink;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -22,8 +22,8 @@ import java.util.Map;
|
|||
import jakarta.websocket.Session;
|
||||
import org.eclipse.jetty.ee10.websocket.jakarta.common.JakartaWebSocketFrameHandlerFactory;
|
||||
import org.eclipse.jetty.util.annotation.Name;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -19,8 +19,8 @@ import java.lang.invoke.MethodHandles;
|
|||
import java.lang.reflect.Method;
|
||||
|
||||
import org.eclipse.jetty.util.annotation.Name;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -17,7 +17,7 @@ import java.lang.annotation.Annotation;
|
|||
import java.lang.reflect.Method;
|
||||
|
||||
import org.eclipse.jetty.util.annotation.Name;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
|
||||
/**
|
||||
* Simple {@link InvokerUtils.ParamIdentifier}
|
||||
|
|
|
@ -13,7 +13,7 @@
|
|||
|
||||
package org.eclipse.jetty.ee10.websocket.jakarta.common.util;
|
||||
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -44,11 +44,11 @@ import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
|||
import org.eclipse.jetty.websocket.core.WebSocketConstants;
|
||||
import org.eclipse.jetty.websocket.core.client.WebSocketCoreClient;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.server.Handshaker;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketMappings;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketNegotiator;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketServerComponents;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -18,7 +18,7 @@ import java.lang.reflect.Method;
|
|||
|
||||
import jakarta.websocket.server.PathParam;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
|
||||
/**
|
||||
* Method argument identifier for {@link jakarta.websocket.server.PathParam} annotations.
|
||||
|
|
|
@ -19,8 +19,8 @@ import java.lang.reflect.Method;
|
|||
import java.util.concurrent.CompletableFuture;
|
||||
|
||||
import org.eclipse.jetty.ee10.websocket.jakarta.common.JakartaWebSocketFrameHandlerFactory;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
|
||||
public class CompletableFutureMethodHandle
|
||||
{
|
||||
|
|
|
@ -19,7 +19,7 @@ import jakarta.websocket.PongMessage;
|
|||
import org.eclipse.jetty.ee10.websocket.jakarta.common.JakartaWebSocketSession;
|
||||
import org.eclipse.jetty.ee10.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.ee10.websocket.jakarta.tests.MessageType;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.hamcrest.Description;
|
||||
import org.hamcrest.TypeSafeMatcher;
|
||||
|
||||
|
|
|
@ -39,10 +39,10 @@ import org.eclipse.jetty.websocket.core.Frame;
|
|||
import org.eclipse.jetty.websocket.core.FrameHandler;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.MessageHandler;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.TextUtils;
|
||||
import org.eclipse.jetty.websocket.core.server.ServerUpgradeRequest;
|
||||
import org.eclipse.jetty.websocket.core.server.ServerUpgradeResponse;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketNegotiator;
|
||||
import org.eclipse.jetty.websocket.core.util.TextUtils;
|
||||
import org.junit.jupiter.api.AfterAll;
|
||||
import org.junit.jupiter.api.AfterEach;
|
||||
import org.junit.jupiter.api.BeforeAll;
|
||||
|
|
|
@ -41,8 +41,8 @@ import org.eclipse.jetty.websocket.core.exception.ProtocolException;
|
|||
import org.eclipse.jetty.websocket.core.exception.UpgradeException;
|
||||
import org.eclipse.jetty.websocket.core.exception.WebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.exception.WebSocketTimeoutException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -49,16 +49,16 @@ import org.eclipse.jetty.websocket.core.CoreSession;
|
|||
import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidWebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.InputStreamMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialStringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ReaderMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.StringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.messages.ByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.ByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.InputStreamMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialStringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.ReaderMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.StringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
|
||||
/**
|
||||
* Factory to create {@link JettyWebSocketFrameHandler} instances suitable for
|
||||
|
|
|
@ -18,7 +18,7 @@ import java.lang.invoke.MethodHandle;
|
|||
import org.eclipse.jetty.ee10.websocket.api.BatchMode;
|
||||
import org.eclipse.jetty.ee10.websocket.api.exceptions.InvalidWebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.Configuration;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
|
||||
public class JettyWebSocketFrameHandlerMetadata extends Configuration.ConfigurationCustomizer
|
||||
{
|
||||
|
|
|
@ -33,7 +33,7 @@ import org.eclipse.jetty.ee10.websocket.api.annotations.OnWebSocketMessage;
|
|||
import org.eclipse.jetty.ee10.websocket.api.annotations.WebSocket;
|
||||
import org.eclipse.jetty.util.BufferUtil;
|
||||
import org.eclipse.jetty.websocket.core.CloseStatus;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.TextUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.TextUtils;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.notNullValue;
|
||||
|
|
|
@ -17,10 +17,10 @@ import org.eclipse.jetty.ee10.websocket.api.exceptions.InvalidWebSocketException
|
|||
import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
||||
import org.eclipse.jetty.websocket.core.exception.DuplicateAnnotationException;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.InputStreamMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ReaderMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.StringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.ByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.InputStreamMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.ReaderMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.StringMessageSink;
|
||||
import org.hamcrest.Matcher;
|
||||
import org.junit.jupiter.api.AfterAll;
|
||||
import org.junit.jupiter.api.BeforeAll;
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.eclipse.jetty.util.FutureCallback;
|
|||
import org.eclipse.jetty.util.IO;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageInputStream;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageInputStream;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -22,7 +22,7 @@ import org.eclipse.jetty.io.ArrayByteBufferPool;
|
|||
import org.eclipse.jetty.io.ByteBufferPool;
|
||||
import org.eclipse.jetty.io.RetainableByteBuffer;
|
||||
import org.eclipse.jetty.util.BufferUtil;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageOutputStream;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageOutputStream;
|
||||
import org.junit.jupiter.api.AfterEach;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
|
|
@ -27,9 +27,9 @@ import org.eclipse.jetty.websocket.core.CloseStatus;
|
|||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.StringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.ByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.StringMessageSink;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -19,8 +19,8 @@ import java.lang.invoke.MethodHandles;
|
|||
import java.lang.reflect.Method;
|
||||
|
||||
import org.eclipse.jetty.util.annotation.Name;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -17,7 +17,7 @@ import java.lang.annotation.Annotation;
|
|||
import java.lang.reflect.Method;
|
||||
|
||||
import org.eclipse.jetty.util.annotation.Name;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
|
||||
/**
|
||||
* Simple {@link InvokerUtils.ParamIdentifier}
|
||||
|
|
|
@ -47,12 +47,12 @@ import org.eclipse.jetty.websocket.core.Configuration;
|
|||
import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
||||
import org.eclipse.jetty.websocket.core.WebSocketConstants;
|
||||
import org.eclipse.jetty.websocket.core.exception.WebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.server.Handshaker;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketCreator;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketMappings;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketNegotiator;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketServerComponents;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -40,7 +40,7 @@ import org.eclipse.jetty.logging.StacklessLogging;
|
|||
import org.eclipse.jetty.server.Server;
|
||||
import org.eclipse.jetty.server.ServerConnector;
|
||||
import org.eclipse.jetty.util.BufferUtil;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.TextUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.TextUtils;
|
||||
import org.junit.jupiter.api.AfterEach;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
|
|
@ -18,7 +18,7 @@ import jakarta.websocket.EndpointConfig;
|
|||
import org.eclipse.jetty.ee9.websocket.jakarta.common.JakartaWebSocketContainer;
|
||||
import org.eclipse.jetty.ee9.websocket.jakarta.common.JakartaWebSocketFrameHandlerFactory;
|
||||
import org.eclipse.jetty.ee9.websocket.jakarta.common.JakartaWebSocketFrameHandlerMetadata;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
|
||||
public class JakartaWebSocketClientFrameHandlerFactory extends JakartaWebSocketFrameHandlerFactory
|
||||
{
|
||||
|
|
|
@ -26,9 +26,9 @@ import org.eclipse.jetty.util.FutureCallback;
|
|||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageOutputStream;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageWriter;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.TextUtils;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageOutputStream;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageWriter;
|
||||
import org.eclipse.jetty.websocket.core.util.TextUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -25,7 +25,7 @@ import org.eclipse.jetty.util.FutureCallback;
|
|||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.TextUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.TextUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -46,11 +46,11 @@ import org.eclipse.jetty.websocket.core.FrameHandler;
|
|||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.exception.ProtocolException;
|
||||
import org.eclipse.jetty.websocket.core.exception.WebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialStringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialStringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -47,12 +47,12 @@ import org.eclipse.jetty.websocket.core.CoreSession;
|
|||
import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidWebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.PartialStringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialByteArrayMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.PartialStringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
|
||||
public abstract class JakartaWebSocketFrameHandlerFactory
|
||||
{
|
||||
|
|
|
@ -17,7 +17,7 @@ import java.lang.invoke.MethodHandle;
|
|||
import java.util.List;
|
||||
|
||||
import org.eclipse.jetty.ee9.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
|
||||
public class JakartaWebSocketMessageMetadata
|
||||
{
|
||||
|
|
|
@ -28,8 +28,8 @@ import org.eclipse.jetty.websocket.core.Frame;
|
|||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.OutgoingFrames;
|
||||
import org.eclipse.jetty.websocket.core.exception.WebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageOutputStream;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageWriter;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageOutputStream;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageWriter;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -38,7 +38,7 @@ import org.eclipse.jetty.ee9.websocket.jakarta.common.encoders.AvailableEncoders
|
|||
import org.eclipse.jetty.util.Callback;
|
||||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.ExtensionConfig;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -29,7 +29,7 @@ import jakarta.websocket.EndpointConfig;
|
|||
import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidWebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
|
||||
public class AvailableDecoders implements Iterable<RegisteredDecoder>, Closeable
|
||||
{
|
||||
|
|
|
@ -29,7 +29,7 @@ import org.eclipse.jetty.ee9.websocket.jakarta.common.InitException;
|
|||
import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidWebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -24,7 +24,7 @@ import org.eclipse.jetty.util.Callback;
|
|||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.exception.CloseException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -25,8 +25,8 @@ import org.eclipse.jetty.ee9.websocket.jakarta.common.JakartaWebSocketFrameHandl
|
|||
import org.eclipse.jetty.ee9.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.exception.CloseException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.ByteBufferMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -26,8 +26,8 @@ import org.eclipse.jetty.ee9.websocket.jakarta.common.JakartaWebSocketFrameHandl
|
|||
import org.eclipse.jetty.ee9.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.exception.CloseException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.InputStreamMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.InputStreamMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
|
||||
public class DecodedBinaryStreamMessageSink<T> extends AbstractDecodedMessageSink.Stream<Decoder.BinaryStream<T>>
|
||||
{
|
||||
|
|
|
@ -24,8 +24,8 @@ import org.eclipse.jetty.ee9.websocket.jakarta.common.JakartaWebSocketFrameHandl
|
|||
import org.eclipse.jetty.ee9.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.exception.CloseException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.StringMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.StringMessageSink;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -26,8 +26,8 @@ import org.eclipse.jetty.ee9.websocket.jakarta.common.JakartaWebSocketFrameHandl
|
|||
import org.eclipse.jetty.ee9.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.exception.CloseException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ReaderMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.ReaderMessageSink;
|
||||
|
||||
public class DecodedTextStreamMessageSink<T> extends AbstractDecodedMessageSink.Stream<Decoder.TextStream<T>>
|
||||
{
|
||||
|
|
|
@ -16,7 +16,7 @@ package org.eclipse.jetty.ee9.websocket.jakarta.common;
|
|||
import jakarta.websocket.ClientEndpoint;
|
||||
import jakarta.websocket.ClientEndpointConfig;
|
||||
import jakarta.websocket.EndpointConfig;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
|
||||
public class DummyFrameHandlerFactory extends JakartaWebSocketFrameHandlerFactory
|
||||
{
|
||||
|
|
|
@ -32,7 +32,7 @@ import org.eclipse.jetty.util.FutureCallback;
|
|||
import org.eclipse.jetty.util.IO;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.InputStreamMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.InputStreamMessageSink;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static java.nio.charset.StandardCharsets.UTF_8;
|
||||
|
|
|
@ -26,7 +26,7 @@ import org.eclipse.jetty.util.Utf8StringBuilder;
|
|||
import org.eclipse.jetty.websocket.core.CoreSession;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageWriter;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageWriter;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.eclipse.jetty.util.FutureCallback;
|
|||
import org.eclipse.jetty.util.IO;
|
||||
import org.eclipse.jetty.websocket.core.Frame;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.ReaderMessageSink;
|
||||
import org.eclipse.jetty.websocket.core.messages.ReaderMessageSink;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -22,8 +22,8 @@ import java.util.Map;
|
|||
import jakarta.websocket.Session;
|
||||
import org.eclipse.jetty.ee9.websocket.jakarta.common.JakartaWebSocketFrameHandlerFactory;
|
||||
import org.eclipse.jetty.util.annotation.Name;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -19,8 +19,8 @@ import java.lang.invoke.MethodHandles;
|
|||
import java.lang.reflect.Method;
|
||||
|
||||
import org.eclipse.jetty.util.annotation.Name;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -17,7 +17,7 @@ import java.lang.annotation.Annotation;
|
|||
import java.lang.reflect.Method;
|
||||
|
||||
import org.eclipse.jetty.util.annotation.Name;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
|
||||
/**
|
||||
* Simple {@link InvokerUtils.ParamIdentifier}
|
||||
|
|
|
@ -13,7 +13,7 @@
|
|||
|
||||
package org.eclipse.jetty.ee9.websocket.jakarta.common.util;
|
||||
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
|
|
|
@ -45,11 +45,11 @@ import org.eclipse.jetty.websocket.core.WebSocketComponents;
|
|||
import org.eclipse.jetty.websocket.core.WebSocketConstants;
|
||||
import org.eclipse.jetty.websocket.core.client.WebSocketCoreClient;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.server.Handshaker;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketMappings;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketNegotiator;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketServerComponents;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
|
@ -18,7 +18,7 @@ import java.lang.reflect.Method;
|
|||
|
||||
import jakarta.websocket.server.PathParam;
|
||||
import org.eclipse.jetty.websocket.core.exception.InvalidSignatureException;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
|
||||
/**
|
||||
* Method argument identifier for {@link jakarta.websocket.server.PathParam} annotations.
|
||||
|
|
|
@ -19,8 +19,8 @@ import java.lang.reflect.Method;
|
|||
import java.util.concurrent.CompletableFuture;
|
||||
|
||||
import org.eclipse.jetty.ee9.websocket.jakarta.common.JakartaWebSocketFrameHandlerFactory;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
|
||||
public class CompletableFutureMethodHandle
|
||||
{
|
||||
|
|
|
@ -19,7 +19,7 @@ import jakarta.websocket.PongMessage;
|
|||
import org.eclipse.jetty.ee9.websocket.jakarta.common.JakartaWebSocketSession;
|
||||
import org.eclipse.jetty.ee9.websocket.jakarta.common.decoders.RegisteredDecoder;
|
||||
import org.eclipse.jetty.ee9.websocket.jakarta.tests.MessageType;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.ReflectUtils;
|
||||
import org.eclipse.jetty.websocket.core.util.ReflectUtils;
|
||||
import org.hamcrest.Description;
|
||||
import org.hamcrest.TypeSafeMatcher;
|
||||
|
||||
|
|
|
@ -39,10 +39,10 @@ import org.eclipse.jetty.websocket.core.Frame;
|
|||
import org.eclipse.jetty.websocket.core.FrameHandler;
|
||||
import org.eclipse.jetty.websocket.core.OpCode;
|
||||
import org.eclipse.jetty.websocket.core.internal.MessageHandler;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.TextUtils;
|
||||
import org.eclipse.jetty.websocket.core.server.ServerUpgradeRequest;
|
||||
import org.eclipse.jetty.websocket.core.server.ServerUpgradeResponse;
|
||||
import org.eclipse.jetty.websocket.core.server.WebSocketNegotiator;
|
||||
import org.eclipse.jetty.websocket.core.util.TextUtils;
|
||||
import org.junit.jupiter.api.AfterAll;
|
||||
import org.junit.jupiter.api.AfterEach;
|
||||
import org.junit.jupiter.api.BeforeAll;
|
||||
|
|
|
@ -41,8 +41,8 @@ import org.eclipse.jetty.websocket.core.exception.ProtocolException;
|
|||
import org.eclipse.jetty.websocket.core.exception.UpgradeException;
|
||||
import org.eclipse.jetty.websocket.core.exception.WebSocketException;
|
||||
import org.eclipse.jetty.websocket.core.exception.WebSocketTimeoutException;
|
||||
import org.eclipse.jetty.websocket.core.internal.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.internal.util.InvokerUtils;
|
||||
import org.eclipse.jetty.websocket.core.messages.MessageSink;
|
||||
import org.eclipse.jetty.websocket.core.util.InvokerUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue