View Javadoc

1   //
2   //  ========================================================================
3   //  Copyright (c) 1995-2016 Mort Bay Consulting Pty. Ltd.
4   //  ------------------------------------------------------------------------
5   //  All rights reserved. This program and the accompanying materials
6   //  are made available under the terms of the Eclipse Public License v1.0
7   //  and Apache License v2.0 which accompanies this distribution.
8   //
9   //      The Eclipse Public License is available at
10  //      http://www.eclipse.org/legal/epl-v10.html
11  //
12  //      The Apache License v2.0 is available at
13  //      http://www.opensource.org/licenses/apache2.0.php
14  //
15  //  You may elect to redistribute this code under either of these licenses.
16  //  ========================================================================
17  //
18  
19  package org.eclipse.jetty.server;
20  
21  import java.io.IOException;
22  import java.io.OutputStreamWriter;
23  import java.io.UnsupportedEncodingException;
24  import java.io.Writer;
25  
26  /**
27   *
28   */
29  public class EncodingHttpWriter extends HttpWriter
30  {
31      final Writer _converter;
32  
33      /* ------------------------------------------------------------ */
34      public EncodingHttpWriter(HttpOutput out, String encoding)
35      {
36          super(out);
37          try
38          {
39              _converter = new OutputStreamWriter(_bytes, encoding);
40          }
41          catch (UnsupportedEncodingException e)
42          {
43              throw new RuntimeException(e);
44          }
45      }
46  
47      /* ------------------------------------------------------------ */
48      @Override
49      public void write (char[] s,int offset, int length) throws IOException
50      {
51          HttpOutput out = _out;
52          if (length==0 && out.isAllContentWritten())
53          {
54              out.close();
55              return;
56          }
57              
58          while (length > 0)
59          {
60              _bytes.reset();
61              int chars = length>MAX_OUTPUT_CHARS?MAX_OUTPUT_CHARS:length;
62  
63              _converter.write(s, offset, chars);
64              _converter.flush();
65              _bytes.writeTo(out);
66              length-=chars;
67              offset+=chars;
68          }
69      }
70  }