type annotations

jakubwro · Sep 30, 2024 · 55e65b8 · 55e65b8
1 parent 2793282
commit 55e65b8
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/src/experimental/scoped_connection.jl b/src/experimental/scoped_connection.jl
@@ -116,7 +116,7 @@ end
 function request(
     subject::String,
     data = nothing;
-    timeout = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
+    timeout::Union{Real, Period} = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
 )
     request(scoped_connection(), subject, data; timeout)
 end
@@ -125,7 +125,7 @@ function request(
     nreplies::Integer,
     subject::String,
     data = nothing;
-    timeout = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
+    timeout::Union{Real, Period} = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
 )
     request(scoped_connection(), nreplies, subject, data; timeout)
 end
@@ -134,7 +134,7 @@ function request(
     T::Type,
     subject::String,
     data = nothing;
-    timeout = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
+    timeout::Union{Real, Period} = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
 )
     request(T, scoped_connection(), subject, data; timeout)
 end

diff --git a/src/jetstream/stream/info.jl b/src/jetstream/stream/info.jl
@@ -42,7 +42,7 @@ function stream_infos(connection::NATS.Connection, subject = nothing)
     result
 end
 
-function stream_names(connection::NATS.Connection, subject = nothing; timeout = 5.0)
+function stream_names(connection::NATS.Connection, subject::String = nothing; timeout::Union{Real, Period} = 5.0)
     result = String[]
     offset = 0
     req = Dict()

diff --git a/src/reqreply/request.jl b/src/reqreply/request.jl
@@ -38,7 +38,7 @@ function request(
     connection::Connection,
     subject::String,
     data = nothing;
-    timeout = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
+    timeout::Union{Real, Period} = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
 )
     replies = request(connection, 1, subject, data; timeout)
     if isempty(replies)
@@ -72,7 +72,7 @@ function request(
     nreplies::Integer,
     subject::String,
     data = nothing;
-    timeout = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
+    timeout::Union{Real, Period} = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
 )
     find_data_conversion_or_throw(typeof(data))
     if NATS.status(connection) in [NATS.DRAINED, NATS.DRAINING]
@@ -107,7 +107,7 @@ function request(
     connection::Connection,
     subject::String,
     data = nothing;
-    timeout = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
+    timeout::Union{Real, Period} = parse(Float64, get(ENV, "NATS_REQUEST_TIMEOUT_SECONDS", string(DEFAULT_REQUEST_TIMEOUT_SECONDS)))
 )
     find_msg_conversion_or_throw(T)
     result = request(connection, subject, data; timeout)