Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Binary file modified .gradle/8.14.3/checksums/checksums.lock
Binary file not shown.
Binary file modified .gradle/8.14.3/checksums/md5-checksums.bin
Binary file not shown.
Binary file modified .gradle/8.14.3/checksums/sha1-checksums.bin
Binary file not shown.
Binary file modified .gradle/8.14.3/executionHistory/executionHistory.bin
Binary file not shown.
Binary file modified .gradle/8.14.3/executionHistory/executionHistory.lock
Binary file not shown.
Binary file modified .gradle/8.14.3/fileHashes/fileHashes.bin
Binary file not shown.
Binary file modified .gradle/8.14.3/fileHashes/fileHashes.lock
Binary file not shown.
Binary file modified .gradle/buildOutputCleanup/buildOutputCleanup.lock
Binary file not shown.
2 changes: 1 addition & 1 deletion .gradle/buildOutputCleanup/cache.properties
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
#Thu Jul 17 22:51:20 UTC 2025
#Thu Jul 17 23:24:55 UTC 2025
gradle.version=8.14.3
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ Add the dependency in your `pom.xml` file:
<dependency>
<groupId>com.pipedream</groupId>
<artifactId>pipedream</artifactId>
<version>0.0.193</version>
<version>0.0.202</version>
</dependency>
```

Expand Down
5 changes: 3 additions & 2 deletions build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ dependencies {
api 'com.fasterxml.jackson.core:jackson-databind:2.17.2'
api 'com.fasterxml.jackson.datatype:jackson-datatype-jdk8:2.17.2'
api 'com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.17.2'
api 'org.apache.commons:commons-text:1.11.0'
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.8.2'
testImplementation 'org.junit.jupiter:junit-jupiter-engine:5.8.2'
}
Expand Down Expand Up @@ -46,7 +47,7 @@ java {

group = 'com.pipedream'

version = '0.0.193'
version = '0.0.202'

jar {
dependsOn(":generatePomFileForMavenPublication")
Expand Down Expand Up @@ -77,7 +78,7 @@ publishing {
maven(MavenPublication) {
groupId = 'com.pipedream'
artifactId = 'pipedream'
version = '0.0.193'
version = '0.0.202'
from components.java
pom {
name = 'pipedream'
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ private ClientOptions(
{
put("X-Fern-Language", "JAVA");
put("X-Fern-SDK-Name", "com.pipedream.fern:api-sdk");
put("X-Fern-SDK-Version", "0.0.193");
put("X-Fern-SDK-Version", "0.0.202");
}
});
this.headerSuppliers = headerSuppliers;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
import java.util.Objects;
import okhttp3.MediaType;
import okhttp3.RequestBody;
import okhttp3.internal.Util;
import okio.BufferedSink;
import okio.Okio;
import okio.Source;
Expand Down Expand Up @@ -68,12 +67,8 @@ public long contentLength() throws IOException {
*/
@Override
public void writeTo(BufferedSink sink) throws IOException {
Source source = null;
try {
source = Okio.source(inputStream);
try (Source source = Okio.source(inputStream)) {
sink.writeAll(source);
} finally {
Util.closeQuietly(Objects.requireNonNull(source));
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ public final class StreamTest {
@Test
public void testJsonStream() {
List<Map> messages = List.of(Map.of("message", "hello"), Map.of("message", "world"));
List jsonStrings = messages.stream().map(StreamTest::mapToJson).toList();
List jsonStrings = messages.stream().map(StreamTest::mapToJson).collect(Collectors.toList());
String input = String.join("\n", jsonStrings);
StringReader jsonInput = new StringReader(input);
Stream<Map> jsonStream = Stream.fromJson(Map.class, jsonInput);
Expand All @@ -34,7 +34,7 @@ public void testJsonStream() {
@Test
public void testSseStream() {
List<Map> events = List.of(Map.of("event", "start"), Map.of("event", "end"));
List sseStrings = events.stream().map(StreamTest::mapToSse).toList();
List sseStrings = events.stream().map(StreamTest::mapToSse).collect(Collectors.toList());
String input = String.join("\n" + "\n", sseStrings);
StringReader sseInput = new StringReader(input);
Stream<Map> sseStream = Stream.fromSse(Map.class, sseInput);
Expand Down
Loading