1 package org.eclipse.aether.transport.wagon;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import java.nio.ByteBuffer;
23
24 import org.apache.maven.wagon.events.TransferEvent;
25 import org.apache.maven.wagon.observers.AbstractTransferListener;
26 import org.eclipse.aether.spi.connector.transport.TransportListener;
27 import org.eclipse.aether.transfer.TransferCancelledException;
28
29
30
31
32 final class WagonTransferListener
33 extends AbstractTransferListener
34 {
35
36 private final TransportListener listener;
37
38 WagonTransferListener( TransportListener listener )
39 {
40 this.listener = listener;
41 }
42
43 @Override
44 public void transferStarted( TransferEvent event )
45 {
46 try
47 {
48 listener.transportStarted( 0, event.getResource().getContentLength() );
49 }
50 catch ( TransferCancelledException e )
51 {
52
53
54
55
56 }
57 }
58
59 @Override
60 public void transferProgress( TransferEvent event, byte[] buffer, int length )
61 {
62 try
63 {
64 listener.transportProgressed( ByteBuffer.wrap( buffer, 0, length ) );
65 }
66 catch ( TransferCancelledException e )
67 {
68 throw new WagonCancelledException( e );
69 }
70 }
71
72 }