akka-stream - 阿卡流 : Best practice to initialise and dispose resources of a sink-6ren

akka-stream - 阿卡流 : Best practice to initialise and dispose resources of a sink

转载作者：行者123 更新时间：2023-12-01 12:13:22

26

4

我有一个场景，我想将图表的结果写入 CSV。这包括文件的创建、文件编写器的初始化( I'm using this library )，最后，在流完成后，我想再次处理/关闭编写器。

理想情况下，我想将此逻辑封装在接收器中，但我想知道添加初始化和处置逻辑的最佳实践/ Hook 。

最佳答案

给定任何类型的资源，而不仅仅是一个文件，它消耗数据元素以及needs to be closed :

type Data = ???

trait DataConsumer extends Function1[Data, Unit] with AutoCloseable

可以创建一个Sink，使用watchTermination 完成后关闭消费者。 Flow 的方法可以放在前面:

def createDataConsumerSink(dataConsumer: DataConsumer) : Sink[Data,_] = 
  Flow[Data].watchTermination()( (_, f) => f foreach (_ => dataConsumer.close()))
            .to(Sink.foreach[Data](dataConsumer.apply))

关于akka-stream - 阿卡流 : Best practice to initialise and dispose resources of a sink，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/50174849/

26

4

0

文章推荐： flyway - 在 flyway 中删除迁移

文章推荐： java - 为什么不能直接访问hashmap静态变量

文章推荐： java - Android 中的评分(连续添加并保存 HighScore 分数)

文章推荐： java - 如何检测登录网络的设备？

C# 处理 : when dispose and who dispose it
我在 dispose 和 finalize 之间犹豫不决。这是我的示例代码: public class Car:IDisposable { public string name
android - 是否建议在订阅完成后立即调用 Disposable.dispose() ？
我有一个 Activity，我在其中创建并订阅 Single 类的多个实例(每个实例都在单独的后台线程中执行一些工作)。对于每个订阅，我将创建的 Disposable 实例添加到 CompositeD
c# - Service owns disposable Repository that owns disposable DbContext - Dispose IDisposables injected with Unity
我有一个服务、一个存储库和一个 DbContext。存储库拥有 DbContext，服务拥有存储库。我的存储库应该实现 IDisposable 吗？如果是这样，我的服务是否也应该实现 IDispos
c# - 依赖于其他 Disposable 的 Disposable
我有一个基于字符串列表处理文件流的应用程序，字符串可以是磁盘上的文件，也可以是 Zip 文件中的文件。为了清理代码，我想重构打开文件的过程。我创建了一个返回文件内容 Stream 的方法，但是因为流
c# - 在 Dispose 方法中取消 dispose
有没有一种方法可以从 Dispose 方法中取消处置，换句话说，在调用 A.Dispose() 时不处置 A。更新我没有很好地解释，因为我想不出一个很好的方式来表达它。我拥有的是一个在单独线程中运行
c# - Dispose(bool) 中的 disposed 标志到底是什么意思？
如以下示例实现即 https://learn.microsoft.com/en-us/dotnet/standard/garbage-collection/implementing-dispose有一
c# - 外汇警察: "Types that own disposable fields should be disposable"
我开始用 FXCop 来处理我的一些程序集，并注意到一些有趣的事情，我正试图全神贯注。 "Types that declare disposable members should also imple
c# - Form.Dispose() 是否调用 Dispose() 内部的控件？
当我创建表单时，自动生成的代码不包含重写的 Dispose 方法。这是否意味着没有为表单中的所有控件调用 Dispose？最佳答案当您在表单上调用 Dispose 时，它会为其 Controls
c# - WPF代码分析: CA1001 Types that own disposable fields should be disposable
在我的 WPF 应用程序代码中，我收到以下警告: CA1001 Types that own disposable fields should be disposable Implement IDis
dispose - WebMatrix Database.Open... Close() 和 Dispose()
每当我读到 Close() 和 Dispose() 时，我都会看到很多只使用 Using Block 的引用资料，但我还没有找到如何在 WebMatrix C# Razor 语法中使用 Using B
c# - 如何调试 base.Dispose(disposing) 样板上发生的 NullReferenceException
我是 c# 和 VSTO 的新手。我有一个 Excel 插件，我在其中创建了一个功能区和一些可以执行各种操作的新按钮。我在 base.Dispose 中收到 NullReferenceExcept
c# - BinaryReader.Dispose(bool disposing) 创建流的本地引用。为什么？
我在 FCL 代码中发现了一个不寻常的样本。这是 System.IO.BinaryReader 中的方法: protected virtual void Dispose(bool dispo
dispose - 必须为接口(interface) 'System.IDisposable' 实现 Sub Dispose()
我正在尝试遵循以下教程并将其从 C# 转换为 Vb.net http://www.asp.net/mvc/overview/older-versions/getting-started-with-ef
linq - 为什么 FxCop 在没有一次性字段的类上引发错误 "Types that own disposable fields should be disposable"？
我有一个 LINQ 对象，其中添加了一个附加方法。该类没有一次性属性或方法，但 FxCop 引发错误“拥有一次性字段的类型应该是一次性的”并引用该类。到目前为止我已经减少了代码，但仍然收到错误: p
c# - C# : why do we need `dispose pattern` condition? 中的 `if (disposing)`
因此，默认的处理模式实现如下所示: class SomeClass : IDisposable { // Flag: Has Dispose already been called? bo
c# - 为什么这个 Cancellation Disposable 永远不会在 Observable.Dispose() 上被取消？
我在 WinForms 应用程序中使用 RxFramework。我正在尝试运行 Observable 异步并使用 CancellationDisposable 在用户单击按钮时取消操作。但它不工作!
c# - 在 IDisposable 对象数组中使用 Dispose() 或不使用 Dispose() 元素？
有很多从 .NET 中的函数返回 IDisposable 对象数组或列表的示例。例如，Process.GetProcesses()。如果我调用该方法，我是否有责任在遍历数组的所有成员时对它们进行 D
c# - 在 .NET 中重写 Dispose(bool disposing) 有什么意义？
如果我用 C# 编写一个实现 IDisposable 的类，为什么我不能简单地实现 public void Dispose(){ ... } 处理释放任何非托管资源？是 protected virt
java - LibGDX - 是否应该先执行 texture.dispose() 然后再执行 batch.dispose()？或者没有什么不同？
LibGDX - 是否应该先执行 texture.dispose() 然后再执行 batch.dispose()？还是没有什么不同？我有以下简单的代码。我的问题是 texture.dispose()
c# - 检查 IsDisposed 和 Disposing 时为 "Cannot access a disposed object"
当应用程序收到来自服务的调用时，它会为每个调用打开一个表单。用户必须在每个窗口中进行输入并关闭它。为了让用户的工作顺利进行，我试图在显示下一个窗口时重新激活用户正在处理的窗口。执行此操作的方法如下:

首页

博学

6Ren·AI

商城

akka-stream - 阿卡流 : Best practice to initialise and dispose resources of a sink