@@ -233,7 +233,11 @@ defmodule Gnat.Jetstream.API.KV do
233
233
end)
234
234
"""
235
235
def watch ( conn , bucket_name , handler ) do
236
- Gnat.Jetstream.API.KV.Watcher . start_link ( conn: conn , bucket_name: bucket_name , handler: handler )
236
+ Gnat.Jetstream.API.KV.Watcher . start_link (
237
+ conn: conn ,
238
+ bucket_name: bucket_name ,
239
+ handler: handler
240
+ )
237
241
end
238
242
239
243
@ doc ~S"""
@@ -265,14 +269,20 @@ defmodule Gnat.Jetstream.API.KV do
265
269
end
266
270
end
267
271
272
+ @ spec is_kv_bucket_stream? ( stream_name :: binary ( ) ) :: boolean ( )
273
+ @ deprecated "Use Gnat.Jetstream.API.KV.kv_bucket_stream?/1 instead"
274
+ def is_kv_bucket_stream? ( stream_name ) do
275
+ kv_bucket_stream? ( stream_name )
276
+ end
277
+
268
278
@ doc """
269
279
Returns true if the provided stream is a KV bucket, false otherwise
270
280
271
281
## Parameters
272
282
* `stream_name` - the stream name to test
273
283
"""
274
- @ spec is_kv_bucket_stream ?( stream_name :: binary ( ) ) :: boolean ( )
275
- def is_kv_bucket_stream ?( stream_name ) do
284
+ @ spec kv_bucket_stream ?( stream_name :: binary ( ) ) :: boolean ( )
285
+ def kv_bucket_stream ?( stream_name ) do
276
286
String . starts_with? ( stream_name , "KV_" )
277
287
end
278
288
@@ -285,20 +295,20 @@ defmodule Gnat.Jetstream.API.KV do
285
295
stream_names =
286
296
streams
287
297
|> Enum . flat_map ( fn bucket ->
288
- if is_kv_bucket_stream ?( bucket ) do
289
- [ bucket |> String . trim_leading ( @ stream_prefix ) ]
298
+ if kv_bucket_stream ?( bucket ) do
299
+ [ bucket |> String . trim_leading ( @ stream_prefix ) ]
290
300
else
291
- [ ]
301
+ [ ]
292
302
end
293
303
end )
304
+
294
305
{ :ok , stream_names }
295
306
else
296
307
{ :error , reason } ->
297
308
{ :error , reason }
298
309
end
299
310
end
300
311
301
-
302
312
@ doc false
303
313
def stream_name ( bucket_name ) do
304
314
"#{ @ stream_prefix } #{ bucket_name } "
0 commit comments