- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for EndOfStream (0.35 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/protocol/EndOfStream.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.remote.internal.hub.protocol; public class EndOfStream extends InterHubMessage { @Override public String toString() { return "[" + getClass().getSimpleName() + "]"; } @Override public Delivery getDelivery() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 926 bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/QueueInitializer.java
import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; public class QueueInitializer { private EndOfStream endOfStream; void onStatefulMessage(InterHubMessage message) { if (message instanceof EndOfStream) { endOfStream = (EndOfStream) message; } else {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/SkipFirstTextStream.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:13 UTC 2024 - 1.2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/util/LineBufferingOutputStreamTest.groovy
action.text("line 1-") action.endOfStream(null) } def logsPartialLineOnClose() { LineBufferingOutputStream outputStream = new LineBufferingOutputStream(action, eol, 8) when: outputStream.write("line 1".getBytes()) outputStream.close() then: action.text("line 1") action.endOfStream(null) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 12 07:56:08 UTC 2021 - 5.3K bytes - Viewed (0) -
platforms/core-runtime/io/src/test/groovy/org/gradle/internal/io/SkipFirstTextStreamTest.groovy
when: skipper.text("a") skipper.endOfStream(null) then: 1 * delegate.endOfStream(null) 0 * delegate._ } def "does not skip EOS if before first"() { given: def delegate = Mock(TextStream) def skipper = new SkipFirstTextStream(delegate) when: skipper.endOfStream(null) then: 1 * delegate.endOfStream(null)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:13 UTC 2024 - 1.7K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/OutgoingQueue.java
* limitations under the License. */ package org.gradle.internal.remote.internal.hub; import org.gradle.internal.remote.internal.hub.protocol.ChannelMessage; import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.queue.MultiEndPointQueue; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; import org.gradle.internal.remote.internal.hub.protocol.RejectedMessage;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/InterHubMessageSerializer.java
import org.gradle.internal.serialize.StatefulSerializer; import org.gradle.internal.remote.internal.hub.protocol.ChannelIdentifier; import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; import java.io.IOException; import java.util.HashMap; import java.util.Map;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/ConnectionSet.java
* limitations under the License. */ package org.gradle.internal.remote.internal.hub; import org.gradle.internal.remote.internal.RemoteConnection; import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; import org.gradle.internal.remote.internal.hub.queue.EndPointQueue; import java.util.HashSet; import java.util.Set; class ConnectionSet {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/InterHubMessageSerializerTest.groovy
result[2].channel == channelId1 result[2].payload == "payload 3" } def "can serialise EndOfStream"() { when: def serialized = serialize(new EndOfStream()) def result = deserialize(serialized) then: result instanceof EndOfStream } def serialize(InterHubMessage... messages) { def outStr = new ByteArrayOutputStream()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.5K bytes - Viewed (0) -
platforms/core-runtime/io/src/test/groovy/org/gradle/internal/io/LinePerThreadBufferingOutputStreamTest.groovy
then: 1 * action.text("text") 1 * action.endOfStream(null) 0 * action._ } def closeDoesNothingWhenNothingWritten() { TextStream action = Mock() def outstr = new LinePerThreadBufferingOutputStream(action) when: outstr.close() then: 1 * action.endOfStream(null) 0 * action._ }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:13 UTC 2024 - 3K bytes - Viewed (0)