# \#rocket

**URL:** https://discourse.julialang.org/tag/rocket/686.md

[Latest](https://discourse.julialang.org/latest.md) · [Categories](https://discourse.julialang.org/categories.md) · [Tags](https://discourse.julialang.org/tags.md)

---

## [How to write a custom actor that also acts as an observable?](https://discourse.julialang.org/t/how-to-write-a-custom-actor-that-also-acts-as-an-observable/107808)

<div class="topic-metadata">

**Author:** [@oliviermilla](https://discourse.julialang.org/u/oliviermilla)\
**Replies:** 3\
**Last updated:** [December 21, 2024, 5:08pm UTC](https://discourse.julialang.org/t/how-to-write-a-custom-actor-that-also-acts-as-an-observable/107808 "2024-12-21T17:08:55Z")

</div>

Hello, in Rocket, I’d like to do something like this: struct CustomActor1 \<: Actor{Any} # Data end function Rocket.on\_next!(a::CustomActor1, data::Any) #Compute using a's data next!() # send result downstr…

---

## [Rocket.jl - why is teardown logic never called?](https://discourse.julialang.org/t/rocket-jl-why-is-teardown-logic-never-called/123418)

<div class="topic-metadata">

**Author:** [@AUK1939](https://discourse.julialang.org/u/AUK1939)\
**Replies:** 1\
**Last updated:** [December 20, 2024, 6:55am UTC](https://discourse.julialang.org/t/rocket-jl-why-is-teardown-logic-never-called/123418 "2024-12-20T06:55:48Z")

</div>

Here is an example struct MySubscribable \<: Subscribable{Int} end function Rocket.on\_subscribe!(subscribable::MySubscribable, actor) next!(actor, 1) next!(actor, 2) next!(actor, 3) complete!(actor) …

---

## [Multiple \`async\` sources for a \`sync\` \`Rocket.jl\` actor](https://discourse.julialang.org/t/multiple-async-sources-for-a-sync-rocket-jl-actor/61107)

<div class="topic-metadata">

**Author:** [@gasagna](https://discourse.julialang.org/u/gasagna)\
**Replies:** 10\
**Last updated:** [May 18, 2021, 1:07pm UTC](https://discourse.julialang.org/t/multiple-async-sources-for-a-sync-rocket-jl-actor/61107 "2021-05-18T13:07:44Z")

</div>

Hi, I am learning reactive programming with the great package Rocket.jl and have a question (pinging the lead dev @bvdmitri). A MWE of my use case to make my question explicit is shown below. import Rocket struct MyAc…