- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我有一个可观察的集合,我已经将CollectionChanged处理程序绑定(bind)到了。将项目添加到集合时,我需要将事件处理程序绑定(bind)到添加的每个项目。这本身并不难,但是我必须先在单独的线程上做一些事情,然后将事件处理程序绑定(bind)到线程上获得的东西上。
要明确的是,这是这样的
protected override void OnCollectionChanged(System.Collections.Specialized.NotifyCollectionChangedEventArgs e)
{
switch(e.Action)
{
case Add:
Background Operation - registers an event
break;
case Remove:
Background Operation - unregister the event
break;
}
}
最佳答案
简介与假设
使用 react 性扩展绝对可以帮助实现最大的并发性。但是,它并不是普通的Rx,因此,如果您不熟悉Rx,它将有些不容易。实现非常简洁,但是不幸的是,由于使用了很多Rx概念,因此解释冗长。
为了使事情尽可能的理智,我做以下假设:
Equals
实现,以实现对添加和删除事件的正确分组IDisposable
和您的
Dispose
。签名如下:
private IDisposable HandleAddRemove<T>(
ObservableCollection<T> collection,
Func<T, Task> addActionAsync,
Func<T, Task> removeActionAsync)
ObservableCollection<T>
private IEnumerable<Func<T, Task>> GetAddRemoveLoop<T>(
Func<T, Task> addFunc,
Func<T, Task> removeFunc)
{
while (true)
{
yield return addFunc;
yield return removeFunc;
}
}
private IDisposable HandleAddRemove<T>(
ObservableCollection<T> collection,
Func<T, Task> addActionAsync,
Func<T, Task> removeActionAsync)
{
return Observable
.FromEventPattern<NotifyCollectionChangedEventHandler, NotifyCollectionChangedEventArgs>(
h => collection.CollectionChanged += h,
h => collection.CollectionChanged -= h)
.Select(evt => evt.EventArgs)
.Where(item => item.Action == NotifyCollectionChangedAction.Add ||
item.Action == NotifyCollectionChangedAction.Remove)
.Select(x => x.Action == NotifyCollectionChangedAction.Add
? (T) x.NewItems[0]
: (T) x.OldItems[0])
.GroupBy(item => item)
.SelectMany(item => item.Zip(
GetAddRemoveLoop(addActionAsync, removeActionAsync),
(i, action) => Observable.Defer(() => action(i).ToObservable())).Concat())
.Subscribe();
}
FromEventPattern
创建一个
IObservable<EventPattern<XXXEventArgs>>
。看起来有些奇怪-参数是委托(delegate),只要结果的可观察项被订阅或完成(正常或异常),它们就会被挂接到事件并与事件分离。
Observable.FromEventPattern
<NotifyCollectionChangedEventHandler, NotifyCollectionChangedEventArgs>(
h => collection.CollectionChanged += h,
h => collection.CollectionChanged -= h)
EventPattern
有点笨拙-我们只需要使用
EventArgs
属性,以便我们可以使用
Select
转换每个项目:
.Select(evt => evt.EventArgs)
Add
和
Remove
Action 以外的所有 Action 。我们使用
Where
运算符执行此操作:
.Where(item => item.Action == NotifyCollectionChangedAction.Add ||
item.Action == NotifyCollectionChangedAction.Remove)
NewItems
集合中只有一个项目,对于Remove操作,
OldItems
集合中恰好有一个项目。此
Select
根据操作类型适本地提取项目:
.Select(x => x.Action == NotifyCollectionChangedAction.Add
? (T) x.NewItems[0]
: (T) x.OldItems[0])
.Equals
的一个良好实现:
.GroupBy(item => item)
IObservable<IGroupedObservable<T,T>>
!群流。组流中有两个类型参数。一个用于 key ,另一个用于组中的项目。在这种情况下,我们将项目本身用作键,因此类型参数都是
T
。添加了
Key
属性后,分组的可观察对象就像常规可观察对象一样。
Add(item)
或
Remove(item)
一次。第一个用于
Add
,第二个用于
Remove
,依此类推。
SelectMany
-让我们先看一下它的内部:
Zip
运算符,该运算符会将组流中的每个项目与前面所述的辅助函数产生的可枚举返回的添加/删除工厂函数配对。
Zip
的第一个参数是可枚举的-对我们的辅助函数的调用。
item.Zip(GetAddRemoveLoop(addActionAsync, removeActionAsync),
(i, action) => /* get result of combining item and action */)
IObservable<TResult>
,其中
TResult
是选择器函数返回的类型。
Task
,在添加/删除操作完成后完成)的调用转换为
IObservable
流。有一个方便的扩展方法,可以将
Task
转换为称为
IObservable
的
ToObservable
。对于简单的Task,它使用特殊的类型
Unit
作为返回类型。
Unit
是一种常见的功能类型,当您需要知道已完成某件事但并不关心它是什么时,将使用它。因此,
ToObservable
将给我们一个表示我们的异步任务的
IObservable<Unit>
。
(i, action) => action(i).ToObservable();
IObservable<Unit>
时调用添加/删除任务。
Observable.Defer
将为我们做到这一点,仅调用您在订阅时通过它的操作。因此,除了上面的我们,我们做的是:
(i, action) => Observable.Defer(() => action(i).ToObservable())
Zip
函数,并生成了一个
IObservable<IObservable<Unit>>
流,该流代表表示添加/删除的备用调用。
Concat
。仅当先前的子流已经结束时,这使订阅每个子流的流的流合并。因此,它将
IObservable<IObservable<Unit>>
转换为平面
IObservable<Unit>
。
SelectMany
。我们在组上使用它来获取所有单个组流并将它们展平为单个流。我们正在转换
IObservable<IGroupedObservable<T,T>>
->
IObservable<Unit>
:
.SelectMany(item => // the Zip and Concat result
// that produced the `IObservable<Unit>` of add/remove tasks
IDisposable
,否则该流不会结束:
.Subscribe();
FromEventArgs
。
IDisposable
事件,请记住处置返回的
CollectionChanged
。
private IDisposable HandleAddRemove<T>(
ObservableCollection<T> collection,
Func<T, Task> addActionAsync,
Func<T, Task> removeActionAsync)
{
return Observable
.FromEventPattern<NotifyCollectionChangedEventHandler, NotifyCollectionChangedEventArgs>(
h => collection.CollectionChanged += h,
h => collection.CollectionChanged -= h)
.Select(evt => evt.EventArgs)
.Where(item => item.Action == NotifyCollectionChangedAction.Add ||
item.Action == NotifyCollectionChangedAction.Remove)
.Select(x => x.Action == NotifyCollectionChangedAction.Add
? (T) x.NewItems[0]
: (T) x.OldItems[0])
.GroupBy(item => item)
.SelectMany(item => item.Zip(
GetAddRemoveLoop(addActionAsync, removeActionAsync),
(i, action) => Observable.Defer(() => action(i).ToObservable())).Concat())
.Subscribe();
}
var collection = new ObservableCollection<string>();
Func<string, Task> addAction = x =>
{
Console.WriteLine("Begin add task for " + x);
return Task.Delay(2000)
.ContinueWith(t => Console.WriteLine("End add task for " + x));
};
Func<string, Task> removeAction = x =>
{
Console.WriteLine("Begin remove task for " + x);
return Task.Delay(3000)
.ContinueWith(t => Console.WriteLine("End remove task for " + x));
};
var sub = HandleAddRemove(
collection,
addAction,
removeAction);
collection.Add("item1");
Thread.Sleep(1000);
collection.Remove("item1");
Thread.Sleep(1000);
collection.Add("item2");
collection.Add("item3");
Thread.Sleep(5000);
collection.Remove("item3");
Thread.Sleep(1000);
collection.Remove("item2");
Thread.Sleep(30000);
Console.WriteLine("Done");
sub.Dispose();
Begin add task for item1
Begin add task for item2
Begin add task for item3
End add task for item1
Begin remove task for item1
End add task for item3
End add task for item2
End remove task for item1
Begin remove task for item3
Begin remove task for item2
End remove task for item3
End remove task for item2
Done
关于c# - 处理除集合之外的绑定(bind)事件,以及在删除C#时取消绑定(bind)的事件-多线程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20113507/
SQLite、Content provider 和 Shared Preference 之间的所有已知区别。 但我想知道什么时候需要根据情况使用 SQLite 或 Content Provider 或
警告:我正在使用一个我无法完全控制的后端,所以我正在努力解决 Backbone 中的一些注意事项,这些注意事项可能在其他地方更好地解决......不幸的是,我别无选择,只能在这里处理它们! 所以,我的
我一整天都在挣扎。我的预输入搜索表达式与远程 json 数据完美配合。但是当我尝试使用相同的 json 数据作为预取数据时,建议为空。点击第一个标志后,我收到预定义消息“无法找到任何内容...”,结果
我正在制作一个模拟 NHL 选秀彩票的程序,其中屏幕右侧应该有一个 JTextField,并且在左侧绘制弹跳的选秀球。我创建了一个名为 Ball 的类,它实现了 Runnable,并在我的主 Draf
这个问题已经有答案了: How can I calculate a time span in Java and format the output? (18 个回答) 已关闭 9 年前。 这是我的代码
我有一个 ASP.NET Web API 应用程序在我的本地 IIS 实例上运行。 Web 应用程序配置有 CORS。我调用的 Web API 方法类似于: [POST("/API/{foo}/{ba
我将用户输入的时间和日期作为: DatePicker dp = (DatePicker) findViewById(R.id.datePicker); TimePicker tp = (TimePic
放宽“邻居”的标准是否足够,或者是否有其他标准行动可以采取? 最佳答案 如果所有相邻解决方案都是 Tabu,则听起来您的 Tabu 列表的大小太长或您的释放策略太严格。一个好的 Tabu 列表长度是
我正在阅读来自 cppreference 的代码示例: #include #include #include #include template void print_queue(T& q)
我快疯了,我试图理解工具提示的行为,但没有成功。 1. 第一个问题是当我尝试通过插件(按钮 1)在点击事件中使用它时 -> 如果您转到 Fiddle,您会在“内容”内看到该函数' 每次点击都会调用该属
我在功能组件中有以下代码: const [ folder, setFolder ] = useState([]); const folderData = useContext(FolderContex
我在使用预签名网址和 AFNetworking 3.0 从 S3 获取图像时遇到问题。我可以使用 NSMutableURLRequest 和 NSURLSession 获取图像,但是当我使用 AFHT
我正在使用 Oracle ojdbc 12 和 Java 8 处理 Oracle UCP 管理器的问题。当 UCP 池启动失败时,我希望关闭它创建的连接。 当池初始化期间遇到 ORA-02391:超过
关闭。此题需要details or clarity 。目前不接受答案。 想要改进这个问题吗?通过 editing this post 添加详细信息并澄清问题. 已关闭 9 年前。 Improve
引用这个plunker: https://plnkr.co/edit/GWsbdDWVvBYNMqyxzlLY?p=preview 我在 styles.css 文件和 src/app.ts 文件中指定
为什么我的条形这么细?我尝试将宽度设置为 1,它们变得非常厚。我不知道还能尝试什么。默认厚度为 0.8,这是应该的样子吗? import matplotlib.pyplot as plt import
当我编写时,查询按预期执行: SELECT id, day2.count - day1.count AS diff FROM day1 NATURAL JOIN day2; 但我真正想要的是右连接。当
我有以下时间数据: 0 08/01/16 13:07:46,335437 1 18/02/16 08:40:40,565575 2 14/01/16 22:2
一些背景知识 -我的 NodeJS 服务器在端口 3001 上运行,我的 React 应用程序在端口 3000 上运行。我在 React 应用程序 package.json 中设置了一个代理来代理对端
我面临着一个愚蠢的问题。我试图在我的 Angular 应用程序中延迟加载我的图像,我已经尝试过这个2: 但是他们都设置了 src attr 而不是 data-src,我在这里遗漏了什么吗?保留 d
我是一名优秀的程序员,十分优秀!