Skip to content

Commit

Permalink
fix: rename getStreeamPath to getStreamPath
Browse files Browse the repository at this point in the history
  • Loading branch information
stklcode committed Jun 29, 2024
1 parent ff2650e commit 50e9835
Show file tree
Hide file tree
Showing 4 changed files with 16 additions and 4 deletions.
12 changes: 12 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,10 @@
All notable changes to this project will be documented in this file.

## unreleased

### Fixed
* renamed `UraClientConfiguration#getStreeamPath()` to `getStreamPath()`

### Dependencies
* Updated Jackson dependency to 2.17.1

Expand Down Expand Up @@ -71,6 +75,14 @@ All notable changes to this project will be documented in this file.

----

## 1.3.3 - 2022-11-21
### Security
* Updated Jackson dependency to 2.14.0

### Fixed
* Querying trips and messages with limit directly from `Query` instance (#19)


## 1.3.2 - 2022-08-30

### Improvements
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/de/stklcode/pubtrans/ura/UraClient.java
Original file line number Diff line number Diff line change
Expand Up @@ -314,7 +314,7 @@ public AsyncUraTripReader getTripsStream(final Query query, final List<Consumer<
// Create the reader.
try {
AsyncUraTripReader reader = new AsyncUraTripReader(
URI.create(requestURL(config.getBaseURL() + config.getStreeamPath(), REQUEST_TRIP, query)),
URI.create(requestURL(config.getBaseURL() + config.getStreamPath(), REQUEST_TRIP, query)),
config,
consumers
);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ public String getInstantPath() {
*
* @return Stream endpoint path.
*/
public String getStreeamPath() {
public String getStreamPath() {
return this.streamPath;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ void configBuilderTest() {
UraClientConfiguration config = UraClientConfiguration.forBaseURL(baseURL).build();
assertEquals(baseURL, config.getBaseURL(), "Unexpected base URL");
assertEquals("/interfaces/ura/instant_V1", config.getInstantPath(), "Unexpected default instant path");
assertEquals("/interfaces/ura/stream_V1", config.getStreeamPath(), "Unexpected default stream path");
assertEquals("/interfaces/ura/stream_V1", config.getStreamPath(), "Unexpected default stream path");
assertNull(config.getConnectTimeout(), "No default connection timeout expected");
assertNull(config.getTimeout(), "No default timeout expected");

Expand All @@ -36,7 +36,7 @@ void configBuilderTest() {
.build();
assertEquals(baseURL, config.getBaseURL(), "Unexpected base URL");
assertEquals(instantPath, config.getInstantPath(), "Unexpected custom instant path");
assertEquals(streamPath, config.getStreeamPath(), "Unexpected custom stream path");
assertEquals(streamPath, config.getStreamPath(), "Unexpected custom stream path");

// With timeouts. (#14)
config = UraClientConfiguration.forBaseURL(baseURL)
Expand Down

0 comments on commit 50e9835

Please sign in to comment.