(T obj)
| 590 | } |
| 591 | |
| 592 | @Override |
| 593 | public <T> T copy(T obj) { |
| 594 | ensureRegistrationFinished(); |
| 595 | try { |
| 596 | return copyContext.copyObject(obj); |
| 597 | } catch (Throwable e) { |
| 598 | throw processCopyError(e); |
| 599 | } finally { |
| 600 | copyContext.reset(); |
| 601 | } |
| 602 | } |
| 603 | |
| 604 | private void serializeToStream(OutputStream outputStream, Consumer<MemoryBuffer> function) { |
| 605 | MemoryBuffer buf = getBuffer(); |