@@ -0,0 +1,2380 @@
+/*******************************************************************************%0A * Copyright (C) 2017 Push Technology Ltd.%0A *%0A * Licensed under the Apache License, Version 2.0 (the %22License%22);%0A * you may not use this file except in compliance with the License.%0A * You may obtain a copy of the License at%0A * http://www.apache.org/licenses/LICENSE-2.0%0A *%0A * Unless required by applicable law or agreed to in writing, software%0A * distributed under the License is distributed on an %22AS IS%22 BASIS,%0A * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.%0A * See the License for the specific language governing permissions and%0A * limitations under the License.%0A *******************************************************************************/%0A%0Apackage com.pushtechnology.diffusion.transform.messaging.receive;%0A%0Aimport com.pushtechnology.diffusion.client.callbacks.Stream;%0Aimport com.pushtechnology.diffusion.transform.transformer.TransformationException;%0A%0A/**%0A * A transformed request stream.%0A *%0A * @author Push Technology Limited%0A */%0Apublic interface TransformedRequestStream%3CT, U, V%3E extends Stream %7B%0A%0A    /**%0A     * Notifies the stream of a transformed request.%0A     *%0A     * @param path the path%0A     * @param request the request that could not be transformed%0A     * @param responder a responder for the request%0A     */%0A    void onRequest(String path, U request, Responder%3CV%3E responder);%0A%0A    /**%0A     * Notifies the failure to transform a value.%0A     *%0A     * @param path the path%0A     * @param request the request that could not be transformed%0A     * @param responder a responder for the request%0A     * @param e the exception thrown when attempting to transform the value%0A     */%0A    void onTransformationException(%0A        String path,%0A        T request,%0A        Responder%3CV%3E responder,%0A        TransformationException e);%0A%0A    /**%0A     * Transformed responder.%0A     *%0A     * @param %3CR%3E response type%0A     */%0A    interface Responder%3CR%3E %7B%0A        /**%0A         * Respond to a request.%0A         *%0A         * @param response the response%0A         * @throws TransformationException if the response could not be transformed%0A         */%0A        void respond(R response) throws TransformationException;%0A%0A        /**%0A         * Reject a request.%0A         *%0A         * @param errorMessage the error message%0A         */%0A        void reject(String errorMessage);%0A    %7D%0A%7D%0A

Add interface for transformed request stream.