* limitations under the License.
 */

package org.gradle.internal.serialize;

public class Serializers {
    public static <T> StatefulSerializer<T> stateful(final Serializer<T> serializer) {
        return new StatefulSerializerAdapter<T>(serializer);
    }

    private static class StatefulSerializerAdapter<T> implements StatefulSerializer<T> {

      * Applications that bind to `<POD_IP>` will not be exposed to external pods.

      The latter is a common source of friction when adopting Istio, in particular with stateful services where this is common.

      The new behavior instead forwards the request as is. This matches the behavior a user would see without Istio installed.

module {
  func.func private @f() {
    func.call @g() : () -> ()
    func.return
  }
  func.func private @g() {
    func.call @f() : () -> ()
    func.return
  }
}

// -----
// Test stateful and stateless partitioned calls.
// CHECK-LABEL: func @f
func.func @f() {
  // CHECK: "tf.PartitionedCall"() <{config = "",  config_proto = "", executor_type = "", f = @g}> : () -> ()

 *
 * @since 3.0
 */
public interface LegacySupport {

    /**
     * Sets the currently active session. Some legacy components are basically stateful and their API is missing
     * parameters that would be required to delegate to a stateless component. Saving the session (in a thread-local

Either side can use `rb.CloseWithError(err error)` to signal an error and close the ring buffer. 
Any reads or writes will return the error on next call.

// - the corresponding first block arguments are unused (except for `tf.OpB`
//   which is the defining op of the first result and will be pruned)
// - `tf.OpB` is not stateful
// - `tf.OpB` has only one result, and that result is only passed through to the
//   unused result of the while loop

// CHECK-LABEL: remove_first_result
// CHECK:       tf.WhileRegion

	OpMuxServerMsg

	// OpUnblockSrvMux contains a message that a server mux is unblocked with one.
	// Only Stateful streams has flow control.
	OpUnblockSrvMux

	// OpUnblockClMux contains a message that a client mux is unblocked with one.
	// Only Stateful streams has flow control.
	OpUnblockClMux

	// OpAckMux acknowledges a mux was created.
	OpAckMux

                public void execute(ConnectCompletion completion) {
                    RemoteConnection<Message> remoteConnection;
                    try {
                        remoteConnection = completion.create(Serializers.stateful(serializer));
                    } catch (UncheckedIOException e) {
                        connectionErrorHandler.run();
                        throw e;
                    }

 * Reuses these prefixes and suffixes to efficiently store names or parts of names it has seen before.
 *
 * This class is stateful. Use a new one for each serialization/deserialization attempt.
 */
public class HierarchicalNameSerializer extends AbstractSerializer<String> {

        endpoint1.take(messages1)
        endpoint2.take(messages2)

        then:
        messages1 == [message1, message2]
        messages2 == [message2]
    }

    def "forwards most recent stateful broadcast messages to all new queues"() {
        def id1 = new ChannelIdentifier("channel1")
        def message1 = broadcast()
        def message2 = broadcast()
        def message3 = new EndOfStream()