Skip to content

Commit 45ba18a

Browse files
author
Adriano Santos
committed
chore: update protobuf package
1 parent e07fa4f commit 45ba18a

13 files changed

Lines changed: 5931 additions & 15 deletions

File tree

docs/sdks/elixir/workflows.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@ defmodule SpawnSdkExample.Actors.ClockActor do
190190
Logger.info("[clock] Clock Actor Received Request. Context: #{inspect(ctx)}")
191191

192192
new_value = if is_nil(state), do: 0, else: state.value + 1
193-
new_state = MyState.new(value: new_value)
193+
new_state = %MyState{value: new_value}
194194

195195
Value.of()
196196
|> Value.state(new_state)
@@ -279,7 +279,7 @@ defmodule SpawnSdkExample.Actors.ForwardPipeActor do
279279
Logger.info("Received request with #{msg.value}")
280280

281281
Value.of()
282-
|> Value.response(MyBusinessMessage.new(value: 999))
282+
|> Value.response(%MyBusinessMessage{value: 999})
283283
|> Value.pipe(
284284
Pipe.to("second_actor", "sum_plus_one")
285285
)
@@ -300,7 +300,7 @@ defmodule SpawnSdkExample.Actors.SecondActorExample do
300300
Logger.info("Received request with #{msg.value}")
301301

302302
Value.of()
303-
|> Value.response(MyBusinessMessage.new(value: msg.value + 1))
303+
|> Value.response(%MyBusinessMessage{value: msg.value + 1})
304304
|> Value.void()
305305
end
306306
end

lib/actors/actor/entity/lifecycle/stream_consumer.ex

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,6 @@ defmodule Actors.Actor.Entity.Lifecycle.StreamConsumer do
6767

6868
@spec build_fact(Message.t()) :: Message.t()
6969
defp build_fact(message) do
70-
# %Broadway.Message{data: "{\"ACTION\":\"KEY_ADDED\",\"KEY\":\"MYKEY\",\"VALUE\":\"MYVALUE\"}", metadata: %{headers: [], topic: "actors.mike"}, acknowledger: {OffBroadway.Jetstream.Acknowledger, #Reference<0.743380651.807927811.227242>, %{on_success: :term, reply_to: "$JS.ACK.newtest.projectionviewertest.1.11.11.1725657673932595345.21"}}, batcher: :default, batch_key: :default, batch_mode: :bulk, status: :ok}
71-
7270
message
7371
|> Message.put_data(process_data(message))
7472
end

0 commit comments

Comments
 (0)