src/java.net.http/share/classes/jdk/internal/net/http/common/SubscriberWrapper.java
equal
deleted
inserted
replaced
1 /* |
1 /* |
2 * Copyright (c) 2017, 2018, Oracle and/or its affiliates. All rights reserved. |
2 * Copyright (c) 2017, 2019, Oracle and/or its affiliates. All rights reserved. |
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. |
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. |
4 * |
4 * |
5 * This code is free software; you can redistribute it and/or modify it |
5 * This code is free software; you can redistribute it and/or modify it |
6 * under the terms of the GNU General Public License version 2 only, as |
6 * under the terms of the GNU General Public License version 2 only, as |
7 * published by the Free Software Foundation. Oracle designates this |
7 * published by the Free Software Foundation. Oracle designates this |
466 .append(" downstreamCompleted: ").append(Boolean.toString(downstreamCompleted)) |
466 .append(" downstreamCompleted: ").append(Boolean.toString(downstreamCompleted)) |
467 .append(" completionAcknowledged: ").append(Boolean.toString(completionAcknowledged)) |
467 .append(" completionAcknowledged: ").append(Boolean.toString(completionAcknowledged)) |
468 .append(" outputQ size: ").append(Integer.toString(outputQ.size())) |
468 .append(" outputQ size: ").append(Integer.toString(outputQ.size())) |
469 //.append(" outputQ: ").append(outputQ.toString()) |
469 //.append(" outputQ: ").append(outputQ.toString()) |
470 .append(" cf: ").append(cf.toString()) |
470 .append(" cf: ").append(cf.toString()) |
471 .append(" downstreamSubscription: ").append(downstreamSubscription.toString()); |
471 .append(" downstreamSubscription: ").append(downstreamSubscription) |
|
472 .append(" downstreamSubscriber: ").append(downstreamSubscriber); |
472 |
473 |
473 return sb.toString(); |
474 return sb.toString(); |
474 } |
475 } |
475 |
476 |
476 public String dbgString() { |
477 public String dbgString() { |