如何使用rxjava从SWT表中获取选定的项目？

Question

我有一个表格和一个按钮，我想在单击按钮时发出一个用表格的事件项目。

按钮不应该知道表，并且只能保留为单击流。因此，该解决方案被丢弃：

final ETable table = ... PublishSubject<ItemSelected> selected = PublishSubject.create(); button.addSelectionListener(new SelectionListener(){ @Override public void widgetSelected(SelectionEvent e) { for (TableItem item : table.getSelection()) { selected.onNext(new ItemSelected(item)); } } });

我更喜欢使用表的项目选择流组成按钮的单击流，以保持这两个元素之间的松散耦合。

由于表允许多个选择，我必须首先

Scan

为了发出所有项目的事件，选择的项目。类似：

public static class ItemsSelected<T> { final List<T> items = new ArrayList<T>(); } public abstract static class ItemSelection<T> { public abstract void apply(ItemsSelected<T> selection); } public static class ItemUnselected<T> extends ItemSelection<T> { final T item; public ItemUnselected(T item) { this.item = item; } public void apply(ItemsSelected<T> selection) { selection.items.remove(item); } } public static class ItemSelected<T> extends ItemSelection<T> { final T item; public ItemSelected(T item) { this.item = item; } public void apply(ItemsSelected<T> selection) { selection.items.add(item); } } public static class ObservableTable<T> extends Table { private PublishSubject<ItemSelection<T>> clicks = PublishSubject.create(); public Observable<ItemsSelected<T>> selection = clicks.scan(new ItemsSelected<T>(), new Func2<ItemsSelected<T>, ItemSelection<T>, ItemsSelected<T>>() { @Override public ItemsSelected<T> call(ItemsSelected<T> t1, ItemSelection<T> t2) { // breaking events immutability t2.apply(t1); return t1; } }); public ObservableTable(Composite parent, int style) { super(parent, style); this.addSelectionListener(new SelectionListener() { @SuppressWarnings("unchecked") @Override public void widgetSelected(SelectionEvent e) { if (((TableItem) e.item).getChecked()) clicks.onNext(new ItemSelected<T>((T) e.item.getData())); else clicks.onNext(new ItemUnselected<T>((T) e.item.getData())); } @Override public void widgetDefaultSelected(SelectionEvent e) { } }); } }

，然后我必须将表格流与按钮。单击流中的选项流中。这个想法是，当键盘发出纽扣时，只有在以前发出的项目中排放时，才会发出selectionForaction。

-------S1--U1-----S2---S3--------- table.clicks
           (scan)
-------(1)--()---(2)---(2,3)------ table.selection
                           
----O----------O-------------O---- button.clicks
              (?)
-----------------------------(2,3) selectionForAction

，我应该使用哪个操作？

zip：它不起作用，因为如果我单击按钮并以后选择一个项目，它不应该做任何事情，但是使用zip会发出事件。

join：我最终使用

join

table.selection.join(button.clicks, new Func1<ItemsSelected,Observable<Long>>() { @Override public Observable<Long> call(ItemsSelected t) { // it doesn't seem a good idea return Observable.timer(1, TimeUnit.DAYS); } }, new Func1<ClickEvent, Observable<Long>>() { @Override public Observable<Long> call(ClickEvent t) { // this makes the ClickEvent be dropped if there is no previous ItemsSelected event emitted return Observable.timer(1, TimeUnit.MILLISECONDS); } }, new Func2<ItemsSelected, ClickEvent, SelectionForAction>() { @Override public SelectionForActioncall(ItemsSelected t1, ClickEvent t2) { return new SelectionForAction(t1.items); } }); 任何想法？

我发现了我需要使用非常大的时间单元（示例中的几天）和一个很小的（毫秒）来实现