Brian Groenke
Brian Groenke
I also have this issue, I think it is also corrupting the files.... but I am not sure. Version 1.9.2-1.
:+1: Can we get some input from collaborators....?
It's been a while since I've looked at this... but I just pushed the changes I had made to my remote fork. So you can take a look here: https://github.com/bgroenks96/mbassador/tree/add-event-bus-pause-resume
Are you referring to the 'pauseAsync' stuff or the code in AbstractPubSubPauseSupport? I haven't fully implemented and/or reviewed how this will work with async. I actually was hoping for your...
How does [this](https://github.com/bgroenks96/mbassador/blob/add-event-bus-pause-resume/src/main/java/net/engio/mbassy/bus/SuspendableMBassador.java) look?
Ok, I added another constructor and a new 'resumeAsync' method. [How does that look?](https://github.com/bgroenks96/mbassador/blob/add-event-bus-pause-resume/src/main/java/net/engio/mbassy/bus/SuspendableMBassador.java) Now you just need unit tests?
> The implementation of publish() and publishAsync() violates the DRY principle and needs to be refactored. So would you prefer to just have something like `resume(boolean async)`? I think I...
@bennidi I think I have discovered several issues with taking the spring-like wrapper pattern you suggested: 1) It makes it impossible to extend `MBassador` and treat the new pause/resume bus...
@bennidi It's been a while, but I am still interested to know what you think about this and about #131
Possibly related to #415. But you should make sure your operation `Dtt.(f) .~ (S + laplacians)/(μ_0*ε_0)` is properly broadcasted; i.e. it should be (I think) `Dtt.(f) .~ (S .+ laplacians)./(μ_0*ε_0)`