* @return the new lease state
     */
    public int getNewLeaseState() {
        return newLeaseState;
    }

    /**
     * Gets the reason for the lease break
     * @return the break reason
     */
    public int getBreakReason() {
        return breakReason;
    }

    /**
     * Gets the lease flags from the notification
     * @return the lease flags
     */
    public int getLeaseFlags() {

                return ticket.getSessionKey();
            }
        }
        return null;
    }

    /**
     * {@inheritDoc}
     *
     * @see java.lang.Object#toString()
     */
    @Override
    public String toString() {
        if (this.gssContext == null || !this.gssContext.isEstablished()) {

            }
            return new ProjectBuilderResult() {
                @Override
                public ProjectBuilderRequest getRequest() {
                    return request;
                }

                @Nonnull
                @Override
                public String getProjectId() {
                    return res.getProjectId();
                }

      if (from == Bound.NO_BOUND && to == Bound.INCLUSIVE) {
        return map.headMap(lastInclusive, true);
      } else if (from == Bound.EXCLUSIVE && to == Bound.NO_BOUND) {
        return map.tailMap(firstExclusive, false);
      } else if (from == Bound.EXCLUSIVE && to == Bound.EXCLUSIVE) {
        return map.subMap(firstExclusive, false, lastExclusive, false);

                    public String foo() { return "bar"; }
                }
            """,
            v2 = """
                import $nullableAnnotationName;
                public class Source {
                    @Nullable public String nonFinalField = null;
                    @Nullable public final String finalField = null;
                    @Nullable public String foo() { return "bar"; }
                }
            """

     */
    public static ResourceManager getInstance() {
        return INSTANCE;
    }

    /**
     * Register a resource for tracking
     *
     * @param resource the resource to track
     * @return resource ID for tracking
     */
    public String registerResource(AutoCloseable resource) {
        if (resource == null) {

			wg.Wait()
			m.checkRemoteAlive()
		}()
	}
	return &m
}

// handleInbound sends unblocks when we have delivered the message to the handler.
func (m *muxServer) handleInbound(c *Connection, inbound <-chan []byte, handlerIn chan<- []byte) {
	for {
		select {
		case <-m.ctx.Done():
			return
		case in, ok := <-inbound:
			if !ok {
				return
			}
			select {
			case <-m.ctx.Done():
				return

        // Return just the base; caller is responsible for placing ctx at the correct absolute offset.
        // We will return a composite buffer from the test when building the full packet.
        // To keep this helper simple, return base and let the caller append/pad and inject ctx.
        return base;
    }

    /**

        }
        return new String(c);
    }

    /**
     * Converts a byte array to a hexadecimal string representation.
     *
     * @param data the byte array to convert
     * @return a hexadecimal string representation of the entire byte array
     */
    public static String toHexString(final byte[] data) {
        return toHexString(data, 0, data.length);
    }

    /**

    /**
     * Normalizes the string representation of a number.
     *
     * @param s
     *            A string representing a number
     * @return The normalized string
     * @see #normalize(String, Locale)
     */
    public static String normalize(final String s) {
        return normalize(s, LocaleUtil.getDefault());
    }

    /**
     * Normalizes the string representation of a number by removing grouping separators